CPC G06F 16/215 (2019.01) [G06F 16/2282 (2019.01); G06F 16/24568 (2019.01); G06F 16/254 (2019.01)] | 20 Claims |
1. A method of publishing event messages, comprising:
receiving messages corresponding to a plurality of events from a database, each message indicating a changed entry in the database for an associated event;
identifying, for a first event of the plurality of events, one or more tables of the database corresponding to the first event that have at least one changed entry;
parsing a group of the received messages that share a common identifier associated with the first event;
assigning an event type to the first event and to the group of received messages associated with the first event based at least in part on a highest priority change type of the changed entries of the one or more identified tables of the database; and
publishing the group of received messages associated with the first event on an event streaming platform based on the assigned event type being the same for each message of the group of received messages, the event streaming platform configured to stream, in real-time, the group of received messages associated with the first event to downstream users over one or more signal lines.
|