Sequence engine

摘要

According to one aspect, embodiments of the invention provide a data replicator comprising a system exit configured to capture data received at a source, a configuration control system configured to receive captured data from the system exit and modify the captured data to include sequence information, a message broker configured to receive the modified data from the configuration control system and to convert the modified data to a format of a destination, and a sequence engine configured to receive the converted and modified data from the message broker in a first sequence, to re-sequence, based on the sequence information, the converted and modified data in the first sequence into a second sequence, where the second sequence corresponds to the chronological order in which the data was captured by the system exit, and to forward the converted and modified data to the destination database in the second sequence.

主权项

1. A data replicator comprising:
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, the captured data including a plurality of individual messages; a configuration control system in communication with the at least one system exit, the configuration control system configured to receive captured data from the at least one system exit and to modify each one of the plurality of individual messages to include sequence information, the sequence information representative of a chronological order in which each one of the plurality of individual messages was captured by the at least one system exit; 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 to a format of a destination database; and a sequence engine in communication with the message broker, the sequence engine configured to receive the converted and modified plurality of individual messages from the message broker in a first sequence, to re-sequence, based on the sequence information, the converted and modified plurality of individual messages in the first sequence into a second sequence, where the second sequence corresponds to the chronological order in which the plurality of individual messages were captured by the at least one system exit, and to forward the converted and modified plurality of individual messages to the destination database in the second sequence.