Patent ID: 9146978
Filing Date: 2015-09-29
Classification: G06F

Abstract:
1. A data replicator comprising: one or more processors of a computing system; 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 message broker in communication with the at least one system exit, the message broker configured to receive the plurality of individual messages from the configuration control system and to convert the plurality of individual messages to a format of a destination database; and a sequence engine in communication with the message broker via a channel, the sequence engine configured to receive and store the converted plurality of individual messages from the message broker, to re-sequence the converted plurality of individual messages into a desired sequence, and to provide the re-sequenced messages to a destination database in the desired sequence; wherein the sequence engine includes a message throttle which is configured to close the channel between the message broker and the sequence engine in response to a determination by the message throttle that the sequence engine cannot receive additional converted individual messages, wherein the sequence engine further includes a message queue in communication with the channel and wherein the message queue is configured to receive and store the converted plurality of individual message from the message broker, wherein the message throttle is further configured to monitor a total number of individual messages stored in the message queue and close the channel between the message broker and the sequence engine in response to a determination that the total number of individual messages stored in the message queue exceeds a first threshold, wherein the sequence engine is further configured to re-sequence the converted plurality of individual messages into the desired sequence based on a chronological order in which the plurality of individual messages were captured by the at least one system exit, and wherein the message throttle is further configured to open the channel between the message broker and the sequence engine in response to a determination that the total number of individual messages stored in the message queue is less than a second threshold.