Apparatus, system, and method of elastically processing message information from multiple sources
First Claim
Patent Images
1. An electronic data message processing apparatus comprising:
- gateway interface circuitry having different data message feed ports and configured to receive different data messages from multiple different data message sources, each data message source having generated a respective chronological sequence of data messages, where data messages received at multiple ones of the different data message feed ports are received out of chronological sequence; and
processing circuitry coupled to the gateway interface and configured to;
buffer received data messages from all of the different data message feed ports;
compare a next message time associated with one of the buffered data messages waiting to be processed to a current feed time of a latest processed data message from the feed ports;
when the next message time exceeds the current feed time, (i) set the current feed time to the next message time and (ii) adapt a data message processing latency time, corresponding to a difference between the current feed time and a reference time that is later than the current feed time, to a difference between the next message time and the reference time, wherein the adapted data message processing latency time accounts for the data messages received at all of the different data message feed ports out of chronological sequence and provides a consolidated and chronological sequence for all of the data messages received from the multiple different data message feed ports; and
generate within the adapted data message processing latency time a combined data message stream including all of the data messages received at all of the multiple different data message feed ports so that all of the data messages in the combined data message stream are transmitted in the consolidated and chronological sequence to one or more destination ports,wherein the processing circuitry is further configured to;
detect a state parameter;
process data messages received from all of the different data message feed ports up and until the state parameter changes as being in chronological sequence;
process data messages received from all of the different data message feed ports after the state parameter changes as being out of chronological sequence; and
adapt the data message processing latency time in order to sort and order the data messages received after the state parameter changes and to provide the consolidated and chronological sequence for the combined data message stream including the data messages received after the state parameter changes.
2 Assignments
0 Petitions
Accused Products
Abstract
Elastic message tracking apparatus and methods are provided that opportunistically improve on the latency of a message processing system and increase the accuracy of a consolidated message stream generated from message streams received from multiple message sources. The elastic message tracking apparatus and methods reduce that latency in situations where the actual latency of all the message streams is lower than a predetermined latency value.
16 Citations
23 Claims
-
1. An electronic data message processing apparatus comprising:
-
gateway interface circuitry having different data message feed ports and configured to receive different data messages from multiple different data message sources, each data message source having generated a respective chronological sequence of data messages, where data messages received at multiple ones of the different data message feed ports are received out of chronological sequence; and processing circuitry coupled to the gateway interface and configured to; buffer received data messages from all of the different data message feed ports; compare a next message time associated with one of the buffered data messages waiting to be processed to a current feed time of a latest processed data message from the feed ports; when the next message time exceeds the current feed time, (i) set the current feed time to the next message time and (ii) adapt a data message processing latency time, corresponding to a difference between the current feed time and a reference time that is later than the current feed time, to a difference between the next message time and the reference time, wherein the adapted data message processing latency time accounts for the data messages received at all of the different data message feed ports out of chronological sequence and provides a consolidated and chronological sequence for all of the data messages received from the multiple different data message feed ports; and generate within the adapted data message processing latency time a combined data message stream including all of the data messages received at all of the multiple different data message feed ports so that all of the data messages in the combined data message stream are transmitted in the consolidated and chronological sequence to one or more destination ports, wherein the processing circuitry is further configured to; detect a state parameter; process data messages received from all of the different data message feed ports up and until the state parameter changes as being in chronological sequence; process data messages received from all of the different data message feed ports after the state parameter changes as being out of chronological sequence; and adapt the data message processing latency time in order to sort and order the data messages received after the state parameter changes and to provide the consolidated and chronological sequence for the combined data message stream including the data messages received after the state parameter changes. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
-
-
13. A method implemented in an electronic data message processing apparatus having processing circuitry operatively coupled to different data message feed ports, comprising:
-
receiving at the different data message feed ports different data messages from multiple different data message sources, each data message source having generated a respective chronological sequence of data messages, where data messages received at multiple ones of the different data message feed ports are received out of chronological sequence; buffering received data messages from all of the different data message feed ports; comparing, by processing circuitry, a next message time associated with one of the buffered data messages waiting to be processed to a current feed time of a latest processed data message from the feed ports; when the next message time exceeds the current feed time, the processing circuitry;
(i) setting the current feed time to the next message time and (ii) adapting a data message processing latency time, corresponding to a difference between the current feed time and a reference time that is later than the current feed time, to a difference between the next message time and the reference time, wherein the adapted data message processing latency time accounts for the data messages received at all of the multiple different data message feed ports out of chronological sequence and provides a consolidated and chronological sequence for all of the data messages received from the multiple different data message feed ports; andgenerating within the adapted data message processing latency time a combined data message stream including all of the data messages received at all of the multiple different data message feed ports so that all of the data messages in the combined data message stream are transmitted in the consolidated and chronological sequence to one or more destination ports, wherein the method further comprises the processing circuitry; detecting a state parameter; processing data messages received from all of the different data message feed ports up and until the state parameter changes as being in chronological sequence; processing data messages received from all of the different data message feed ports after the state parameter changes as being out of chronological sequence; adapting the data message processing latency time to sort and order the data messages received after the state parameter changes to provide the consolidated and chronological sequence for the combined data message stream including the data messages received after the state parameter changes. - View Dependent Claims (14, 15, 16, 17, 18, 19, 20, 21, 22, 23)
-
Specification