Patent ID: 7827299

Claim:
A computer-implemented method, comprising: while accepting data change messages from one of a historical data stream and a real time data stream, obtaining, using a computer including a processor, a data change message identifier (DCMID) for a data change message; determining whether the data change message is from the real time data stream; in response to determining that the data change message is from the real time data stream, processing the DCMID against a historical data structure to determine whether the related data change message has been seen in the historical data stream; in response to determining that the data change message is from the historical data stream, processing the DCMID against a real time data structure to determine whether the related data change message has been seen in the real time data stream; determining whether a threshold for a number of DCMIDs that correspond to each other in the real time data stream and the historical data stream has been met; and in response to determining that the threshold has been met, switching from capturing data change messages in the historical data stream to capturing data change messages in the real time data stream.