摘要 |
According to one embodiment, a system includes an event processing module, a notification controller, and a publication manager. The event processing module includes listeners configured to generate a snapshot of a database. The event processing module also includes an event processor configured to compare the snapshot with a stored historical snapshot to determine data elements in the database that changed, to generate a message indicating the plurality of changes, and to push the message to a queue. The notification controller is configured to receive the message from the queue, to determine, based on stored publication rules, a change from the plurality of changes that should be published, and to format the change based on stored format rules. The publication manager is configured to receive the formatted change, to determine, based on stored subscriptions, whether the formatted change should be communicated to a client, and to communicate the change. |