Sequence engine

摘要

According to one aspect, embodiments of the invention provide a sequence engine comprising a local queue configured to receive captured data in a first sequence, the captured data including a plurality of individual messages, each message including sequence information representative of a chronological order in which the messages was captured, a coupling facility in communication with the local queue, the coupling facility comprising a plurality of data tables wherein a first one of the plurality of data tables is configured to store the captured data in the first sequence, and a dispatcher in communication with the plurality of data tables and configured to resequence, based on the sequence information, the captured data into a second sequence, wherein the second sequence corresponds to the chronological order in which the plurality of individual messages were captured, and to forward the captured data to a destination database in the second sequence.

主权项

1. A data replicator comprising: a sequence engine comprising:
a local queue configured to receive captured data in a first sequence, the captured data including a plurality of individual messages, each one of the plurality of individual messages including sequence information representative of a chronological order in which the plurality of individual messages was captured; a coupling facility in communication with the local queue, the coupling facility comprising a plurality of data tables wherein a first one of the plurality of data tables is configured to store the captured data in the first sequence; a dispatcher in communication with the plurality of data tables and configured to resequence, based on the sequence information in the captured data, the captured data into a second sequence, wherein the second sequence corresponds to the chronological order in which the plurality of individual messages were captured, and to forward the captured data to a destination database in the second sequence; at least one system exit configured to be in communication with a source database and to capture data received at the source database in real time; a configuration control system in communication with the at least one system exit, the configuration control system configured to receive the captured data from the at least one system exit and to modify each one of the plurality of individual messages to include the sequence information; and a message broker in communication with the configuration control system, the message broker configured to receive the modified plurality of individual messages from the configuration control system, and to convert the modified plurality of individual messages into a format of a destination database.