HDETAILED ACTION
Notice of Pre-AIA or AIA Status
1. Claims 2-20 are pending in this application. The present application, filed on or after March 16, 2013, is being examined under the first inventor to file provisions of the AIA .
Information Disclosure Statement
2. The information disclosure statement (IDS) submitted on 11/25/2024 is in compliance with the provisions of 37 CFR 1.97. Accordingly, the information disclosure statement is being considered by the examiner.
Double Patenting
4. The nonstatutory double patenting rejection is based on a judicially created doctrine grounded in public policy (a policy reflected in the statute) so as to prevent the unjustified or improper timewise extension of the “right to exclude” granted by a patent and to prevent possible harassment by multiple assignees. A nonstatutory double patenting rejection is appropriate where the conflicting claims are not identical, but at least one examined application claim is not patentably distinct from the reference claim(s) because the examined application claim either is anticipated by, or would have been obvious over, the reference claim. See, e.g., In re Berg, 140 F.3d 1428, 46 USPQ2d 1226 (Fed. Cir. 1998); In re Goodman, 11 F.3d 1046, 29 USPQ2d 2010 (Fed. Cir. 1993); In re Longi, 759 F.2d 887, 225 USPQ 645 (Fed. Cir. 1985); In re Van Ornum, 686 F.2d 937, 214 USPQ 761 (CCPA 1982); In re Vogel, 422 F.2d 438, 164 USPQ 619 (CCPA 1970); In re Thorington, 418 F.2d 528, 163 USPQ 644 (CCPA 1969).
A timely filed terminal disclaimer in compliance with 37 CFR 1.321(c) or 1.321(d) may be used to overcome an actual or provisional rejection based on nonstatutory double patenting provided the reference application or patent either is shown to be commonly owned with the examined application, or claims an invention made as a result of activities undertaken within the scope of a joint research agreement. See MPEP § 717.02 for applications subject to examination under the first inventor to file provisions of the AIA as explained in MPEP § 2159. See MPEP §§ 706.02(l) (1) - 706.02(l) (3) for applications not subject to examination under the first inventor to file provisions of the AIA . A terminal disclaimer must be signed in compliance with 37 CFR 1.321(b).
The USPTO Internet website contains terminal disclaimer forms, which may be used. Please visit www.uspto.gov/patent/patents-forms. The filing date of the application in which the form is filed determines what form (e.g., PTO/SB/25, PTO/SB/26, PTO/AIA /25, or PTO/AIA /26) should be used. A web-based eTerminal Disclaimer may be filled out completely online using web-screens. An eTerminal Disclaimer that meets all requirements is auto-processed and approved immediately upon submission. For more information about eTerminal Disclaimers, refer to www.uspto.gov/patents/process/file/efs/guidance/eTD-info-I.jsp.
5. Claim(s) 2, 4, 6, 12, and 18-19 is/are rejected on the ground of nonstatutory double patenting as being unpatentable over claim(s) 1-2, 4-5, 13, and 17 of U.S. Patent 10,110,540. Although the claims at issue are not identical, they are not patentably distinct from each other because one of ordinary skill in the art would have known the current limitations in Claims 2, 4, 6, 12, and 18-19 of the current application are disclosed in Patent 10,110,540 which includes extra features in the claim limitation and with windowing operations in Kafka Streams with specifying grace periods for out of order data records in order to change a feed port from an inactive to active state.
Claims 2, 4, 6, 12, and 18-19 of the instant application and claims 1-2, 4-5, 13, and 17 of US Patent 10,110,540 are representative of the double patenting issue present
Claims 2, 4, 6, 12, and 18-19 (application 18/958,139)
Claims 1-2, 4-5, 13, and 17 (US Patent 10,110,540)
2. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
processing circuitry coupled to the first feed port and the second feed port and configured to:
transmit circuitry configured to transmit the combined data message stream to one or more data destinations,
wherein the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and (b) process data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
4. The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
6. The electronic data message processing apparatus of claim 2, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at that one data message feed port.
12. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
processing circuitry coupled to the first feed port and the second feed port and configured to:
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more data destinations.
18. The electronic data message processing apparatus of claim 12, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
19. A method comprising:
receiving, at a first feed port and a second feed port, source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages;
comparing, by processing circuitry coupled to the first and second feed ports, a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, the processing circuitry: (i) setting the current feed time to the next message time and (ii) adapting a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
ordering, by the processing circuitry, the received source data messages in a chronological sequence of destination data messages;
generating, by the processing circuitry, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmitting, by transmitting circuitry, the combined data message stream to one or more data destinations.
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.
5. The electronic data message processing apparatus of claim 1, wherein when one of the data message feed ports is determined to be in an inactive state, the processing circuitry is configured to (a) process the data messages in the combined data message stream in chronological order if the one of the data message feed ports is determined to change to an active state within a predetermined recovery time period, and (b) process the data messages in the combined data message stream out of chronological order if the one of the data message feed ports is determined to change to an active state outside of the predetermined recovery time period.
2. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological sequence using the reference time.
4. The electronic data message processing apparatus of claim 1, wherein the one of the buffered data messages waiting to be processed is a next data message currently received at the data message feed ports having a current earliest data message time, and wherein if the data message time is less than the reference time, then the processing circuitry is configured to process that data message and read a next data message at that data message feed port.
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; and
generating 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.
17. The method claim 16, further comprising: halting advance of the reference time while that data message feed port remains in the inactive state based on the determination that the one data message feed port is in an inactive state.
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; and
generating 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.
6. Claim(s) 2-7, 12, 15, and 19-20 is/are rejected on the ground of nonstatutory double patenting as being unpatentable over claim(s) 1-6, 13, 16, 20, and 23 of U.S. Patent 10,581,785. Although the claims at issue are not identical, they are not patentably distinct from each other because one of ordinary skill in the art would have known the current limitations in Claims 2-7, 12, 15, and 19-20 of the current application are disclosed in Patent 10,581,785 which includes extra features in the claim limitation and with windowing operations in Kafka Streams with specifying grace periods for out of order data records in order to change a feed port from an inactive to active state
Claims 2-7, 12, 15, and 19-20 of the instant application and claims 1-6, 13, 16, 20, and 23 of US Patent 10,581,785 are representative of the double patenting issue present.
Claims 2-7, 12, 15, and 19-20 (application 18/958,139)
Claims 1-6, 13, 16, 20, and 23 (Patent 10,581,785)
2. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
processing circuitry coupled to the first feed port and the second feed port and configured to:
transmit circuitry configured to transmit the combined data message stream to one or more data destinations,
wherein the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and (b) process data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
4. The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
5. The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to adapt the latency time based on a difference between the next message time and the reference time.
6. The electronic data message processing apparatus of claim 2, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at that one data message feed port.
7. The electronic data message processing apparatus of claim 2, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
12. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
processing circuitry coupled to the first feed port and the second feed port and configured to:
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more data destinations.
15. The electronic data message processing apparatus of claim 12, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
19. A method comprising:
receiving, at a first feed port and a second feed port, source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages;
comparing, by processing circuitry coupled to the first and second feed ports, a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, the processing circuitry: (i) setting the current feed time to the next message time and (ii) adapting a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
ordering, by the processing circuitry, the received source data messages in a chronological sequence of destination data messages;
generating, by the processing circuitry, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmitting, by transmitting circuitry, the combined data message stream to one or more data destinations.
20. The method in claim 19, further comprising:
processing, by the processing circuitry, data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and
processing, by the processing circuitry, data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
1. An electronic data message processing apparatus comprising:
gateway interface circuitry having different data message feed ports comprising at least a first feed port and a second feed port 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 circuitry 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 received from the first feed port waiting to be processed to a current feed time of a latest processed data message from the second feed port, wherein the reference time is later than the current feed time;
when the next message time for the message from the first feed port exceeds the current feed time for the message from the second feed port, (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 for the message from the second feed port and the reference time, to a difference between the next message time for the message from the first feed port 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 ones of the 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 ones of the 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.
5. The electronic data message processing apparatus of claim 1,
wherein when one of the data message feed ports is determined to be in an inactive state, the processing circuitry is configured to (a) process the data messages in the combined data message stream in chronological order if the one of the data message feed ports is determined to change to an active state within a predetermined recovery time period, and (b) process the data messages in the combined data message stream out of chronological order if the one of the data message feed ports is determined to change to an active state outside of the predetermined recovery time period.
2. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological sequence using the reference time.
3. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to maintain the reference time when a message that is out of chronological message sequence is processed.
4. The electronic data message processing apparatus of claim 1, wherein the one of the buffered data messages waiting to be processed is a next data message currently received at one of the data message feed ports having a current earliest data message time, and wherein if the current earliest data message time is less than the reference time, then the processing circuitry is configured to process that data message and read a next data message at that one data message feed port.
6. The electronic data message processing apparatus of claim 5, wherein based on a determination that the one data message feed port is in an inactive state, the processing circuitry is configured to halt adaptation of the data message processing latency time while that data message feed port remains in the inactive state.
20. An electronic data message processing apparatus, comprising:
means, comprising at least a first feed port and a second feed port, for receiving 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; means for buffering the different data messages received from the multiple different data message sources;
means for comparing a next message time associated with one of the buffered data messages received from the first feed port waiting to be processed to a current feed time of a latest processed data message from the second feed port, wherein the reference time is later than the current feed time;
means, when the next message time for the message from the first feed port exceeds the current feed time for the message from the second feed port, for setting the current feed time to the next message time;
means, when the next message time for the message from the first feed port exceeds the current feed time for the message from the second feed port, for adapting a data message processing latency time, corresponding to a difference between the current feed time for the message from the second feed port and the reference time, to a difference between the next message time for the message from the first feed port and the reference time,
wherein the adapted data message processing latency time accounts for the data messages received at all of the multiple ones 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 ones of the different data message feed ports; and
means for generating 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 ones of the 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.
23. The electronic data message processing apparatus of claim 20, wherein the current feed time is different from a time stamp for a latest processed data message from the second feed port
13. A method implemented in an electronic data message processing apparatus having processing circuitry operatively coupled to different data message feed ports comprising at least a first feed port and a second feed port, 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 received from the first feed port waiting to be processed to a current feed time of a latest processed data message from the second feed port, wherein the reference time is later than the current feed time;
when the next message time for the message from the first feed port exceeds the current feed time for the message from the second feed port, 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 for the message from the second feed port and the reference time, to a difference between the next message time for the message from the first feed port and the reference time for the electronic data message processing apparatus,
wherein the adapted data message processing latency time accounts for the data messages received at all of the multiple ones 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 ones of the different data message feed ports; and
generating 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 ones of the 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.
16. The method claim 13, wherein when one of the data message feed ports is determined to be in an inactive state, the method further comprising: (a) processing the data messages in the combined data message stream in chronological order if the one of the data message feed ports is determined to change to an active state within a predetermined recovery time period, and (b) processing the data messages in the combined data message stream out of chronological order if the one of the data message feed ports is determined to change to an active state outside of the predetermined recovery time period.
7. Claim(s) 2-4, 6-7, 12, 19, and 20 is/are rejected on the ground of nonstatutory double patenting as being unpatentable over claim(s) 1-3, 5-7, 13, 17, and 21 of U.S. Patent 11,159,471. Although the claims at issue are not identical, they are not patentably distinct from each other because one of ordinary skill in the art would have known the current limitations in Claims 2-4, 6-7, 12, 19, and 20 of the current application are disclosed in Patent 11,159,471 which includes extra features in the claim limitation and with windowing operations in Kafka Streams with specifying grace periods for out of order data records in order to change a feed port from an inactive to active state
Claims 2-4, 6-7, 12, 19, and 20 of the instant application and claims 1-3, 5-7, 13, 17, and 21 of US Patent 11,159,471 are representative of the double patenting issue present.
Claims 2-4, 6-7, 12, 19, and 20 (application 18/958,139)
Claims 1-3, 5-7, 13, 17, and 21 (Patent 11,159,471)
2. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
processing circuitry coupled to the first feed port and the second feed port and configured to:
transmit circuitry configured to transmit the combined data message stream to one or more data destinations,
wherein the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and (b) process data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
3. The electronic data message processing apparatus of claim 2, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
4. The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
6. The electronic data message processing apparatus of claim 2, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at that one data message feed port.
7. The electronic data message processing apparatus of claim 2, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
12. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
processing circuitry coupled to the first feed port and the second feed port and configured to:
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more data destinations.
19. A method comprising:
receiving, at a first feed port and a second feed port, source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages;
comparing, by processing circuitry coupled to the first and second feed ports, a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, the processing circuitry: (i) setting the current feed time to the next message time and (ii) adapting a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
ordering, by the processing circuitry, the received source data messages in a chronological sequence of destination data messages;
generating, by the processing circuitry, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmitting, by transmitting circuitry, the combined data message stream to one or more data destinations.
20. The method in claim 19, further comprising:
processing, by the processing circuitry, data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and
processing, by the processing circuitry, data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
1. An electronic data message processing apparatus comprising:
gateway interface circuitry comprising data message feed ports comprising a first feed port and a second feed port and configured to receive data messages from multiple 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 data message feed ports are received out of chronological sequence; and
processing circuitry coupled to the gateway interface circuitry and configured to:
compare a next message time associated with one of the data messages received from the first feed port and waiting to be processed, to a current feed time of a latest processed data message from the second feed port, wherein a reference time is later than the current feed time;
when the next message time for the message from the first feed port exceeds the current feed time for the latest processed data message from the second feed port, (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 for the latest processed data message from the second feed port and the reference time, to a difference between the next message time for the message from the first feed port and the reference time;
order all of the data messages received at all of the multiple ones of the data message feed ports in a chronological sequence of data messages; and
generate, within the adapted data message processing latency time, a combined data message stream that includes the chronological sequence of data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more destination ports.
6. The electronic data message processing apparatus of claim 1, wherein when one of the data message feed ports is determined to be in an inactive state, the processing circuitry is configured to (a) process the data messages in the combined data message stream in chronological order if the one of the data message feed ports is determined to change to an active state within a predetermined recovery time period, and (b) process the data messages in the combined data message stream out of chronological order if the one of the data message feed ports is determined to change to an active state outside of the predetermined recovery time period.
2. The electronic data message processing apparatus of claim 1, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
3. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
5. The electronic data message processing apparatus of claim 1, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the data message feed ports having a current earliest data message time, and wherein if the current earliest data message time is less than the reference time, then the processing circuitry is configured to process that data message and read a next data message at that one data message feed port.
7. The electronic data message processing apparatus of claim 6, wherein based on a determination that the one data message feed port is in an inactive state, the processing circuitry is configured to halt adaptation of the data message processing latency time while that data message feed port remains in the inactive state.
21. An electronic data message processing apparatus, comprising:
means, comprising a first feed port and a second feed port, for receiving data messages from multiple 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 data message feed ports are received out of chronological sequence; means for comparing a next message time associated with one of the data messages received from the first feed port and waiting to be processed to a current feed time of a latest processed data message from the second feed port, wherein a reference time is later than the current feed time;
means, when the next message time for the message from the first feed port exceeds the current feed time for the latest processed data message from the second feed port, for setting the current feed time to the next message time;
means, when the next message time for the message from the first feed port exceeds the current feed time for the latest processed data message from the second feed port, for adapting a data message processing latency time, corresponding to a difference between the current feed time for the latest processed data message from the second feed port and the reference time, to a difference between the next message time for the message from the first feed port and the reference time;
means for ordering all of the data messages received at all of the multiple ones of the data message feed ports in a chronological sequence of data messages;
means for generating, within the adapted data message processing latency time, a combined data message stream that includes the chronological sequence of data messages; and
means for transmitting the combined data message stream to one or more destination ports.
13. A method implemented in an electronic data message processing apparatus comprising processing circuitry operatively coupled to data message feed ports comprising a first feed port and a second feed port, comprising:
receiving at the data message feed ports data messages from multiple 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 data message feed ports are received out of chronological sequence;
comparing, by processing circuitry, a next message time associated with one of the data messages received from the first feed port and waiting to be processed to a current feed time of a latest processed data message from the second feed port, wherein a reference time is later than the current feed time;
when the next message time for the message from the first feed port exceeds the current feed time for the latest processed data message from the second feed port, 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 for the latest processed data message from the second feed port and the reference time, to a difference between the next message time for the message from the first feed port and the reference time for the electronic data message processing apparatus;
ordering all of the data messages received at all of the multiple ones of the data message feed ports in a chronological sequence of data messages; and
generating, within the adapted data message processing latency time, a combined data message stream that includes the chronological sequence of data messages; and
transmitting the combined data message stream to one or more destination ports.
17. The method claim 13, wherein when one of the data message feed ports is determined to be in an inactive state, the method further comprising: (a) processing the data messages in the combined data message stream in chronological order if the one of the data message feed ports is determined to change to an active state within a predetermined recovery time period, and
(b) processing the data messages in the combined data message stream out of chronological order if the one of the data message feed ports is determined to change to an active state outside of the predetermined recovery time period.
8. Claim(s) 2-8, 12, and 15-19 is/are rejected on the ground of nonstatutory double patenting as being unpatentable over claim(s) 1-7, 8-12, and 14 of U.S. Patent 11,671,395. Although the claims at issue are not identical, they are not patentably distinct from each other because one of ordinary skill in the art would have known the current limitations in Claims 2-8, 12, and 15-19 of the current application are disclosed in Patent 11,671,395 which includes extra features in the claim limitation and with windowing operations in Kafka Streams with specifying grace periods for out of order data records in order to change a feed port from an inactive to active state.
Claims 2-8, 12, and 15-19 of the instant application and claims 1-7, 8-12, and 14 of US Patent 11,671,395 are representative of the double patenting issue present.
Claims 2-8, 12, and 15-19 (application 18/958,139)
Claims 1-7, 8-12, and 14 (Patent 11,671,395)
2. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
processing circuitry coupled to the first feed port and the second feed port and configured to:
transmit circuitry configured to transmit the combined data message stream to one or more data destinations,
wherein the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and (b) process data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
3. The electronic data message processing apparatus of claim 2, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
4. The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
5. The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to adapt the latency time based on a difference between the next message time and the reference time.
6. The electronic data message processing apparatus of claim 2, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at that one data message feed port.
7. The electronic data message processing apparatus of claim 2, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
8. The electronic data message processing apparatus of claim 2, wherein each received data message includes a time stamp and the processing circuitry is configured to re- sequence, based on one or more time stamps, one or more data messages received out of sequence.
12. An electronic data message processing apparatus comprising:
a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
processing circuitry coupled to the first feed port and the second feed port and configured to:
order the received source data messages in a chronological sequence of destination data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more data destinations.
15. The electronic data message processing apparatus of claim 12, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
16. The electronic data message processing apparatus of claim 12, wherein the processing circuitry is further configured to process data messages in the combined data message stream and to detect data messages that are out of chronological message sequence based on a reference time that is later than the current feed time.
17. The electronic data message processing apparatus of claim 12, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein if the current earliest data message time is less than a reference time, then the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at the one of the first and second feed ports.
18. The electronic data message processing apparatus of claim 12, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
19. A method comprising:
receiving, at a first feed port and a second feed port, source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages;
comparing, by processing circuitry coupled to the first and second feed ports, a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time exceeding the current feed time, the processing circuitry: (i) setting the current feed time to the next message time and (ii) adapting a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
ordering, by the processing circuitry, the received source data messages in a chronological sequence of destination data messages;
generating, by the processing circuitry, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmitting, by transmitting circuitry, the combined data message stream to one or more data destinations.
1. An electronic data message processing apparatus comprising:
gateway interface circuitry comprising data message feed ports comprising
a first feed port and a second feed port and configured to receive source data messages from source entities, each source module having generated a respective chronological sequence of source data messages, where some of the source data messages received at the data message feed ports are received out of chronological sequence;
and processing circuitry coupled to the gateway interface circuitry and configured to:
compare a next message time associated with one of the source data messages received from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time for the source data message from the first feed port exceeding the current feed time for the latest processed source data message from the second feed port, (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 for the latest processed data message from the second feed port and a reference time;
order the source data messages received at ones of the data message feed ports in a chronological sequence of destination data messages; and
generate, within the adapted data message processing latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more destination entities,
wherein in response to a determination that one of the data message feed ports in an inactive state, the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to a determination that the one of the data message feed ports changed to an active state within a predetermined recovery time period, and (b) process the data messages in the combined data message stream out of chronological order in response to a determination that the one of the data message feed ports changed to an active state outside of the predetermined recovery time period.
2. The electronic data message processing apparatus of claim 1, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
3. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
4. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to adapt a data message processing latency time based on a difference between the next message time for the message from the first feed port and the reference time.
5. The electronic data message processing apparatus of claim 1, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the data message feed ports having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one data message waiting to be processed and read a next data message at that one data message feed port.
6. The electronic data message processing apparatus of claim 1, wherein based on a determination that the one of the data message feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the data message processing latency time while the one of the data message feed ports remains in the inactive state.
7. The electronic data message processing apparatus of claim 1, wherein each received data message includes a time stamp and the processing circuitry is configured to re-sequence, based on one or more time stamps, one or more data messages received out of sequence.
8. An electronic data message processing apparatus comprising:
gateway interface circuitry comprising data message feed ports comprising a
first feed port and a second feed port and configured to receive source data messages from source entities, each source module having generated a respective chronological sequence of source data messages, where some of the source data messages received at the data message feed ports are received out of chronological sequence;
and processing circuitry coupled to the gateway interface circuitry and configured to:
compare a next message time associated with one of the source data messages received from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time for the source data message from the first feed port exceeding the current feed time for the latest processed source data message from the second feed port, (i) set the current feed time to the next message time and (ii) adapt a data message processing latency time;
order the source data messages received at ones of the data message feed ports in a chronological sequence of destination data messages; and
generate, within the adapted data message processing latency time, a combined data message stream that includes the chronological sequence of destination data messages; and
transmit circuitry configured to transmit the combined data message stream to one or more destination entities, wherein in response to a determination that one of the data message feed ports in an inactive state, the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order if the one of the data message feed ports is determined to change to an active state within a predetermined recovery time period, and (b) process the data messages in the combined data message stream out of chronological order in response to a determination that the one of the data message feed ports changed to an active state outside of the predetermined recovery time period.
9. The electronic data message processing apparatus of claim 8, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
10. The electronic data message processing apparatus of claim 8, wherein a reference time is later than the current feed time, and wherein the processing circuitry is further configured to maintain the reference time in response to a message being out of chronological message sequence is processed.
11. The electronic data message processing apparatus of claim 8, wherein: a reference time is later than the current feed time, the one of the data messages waiting to be processed is a next data message currently received at one of the data message feed ports having a current earliest data message time, and in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process that data message and read a next data message at that one data message feed port.
12. The electronic data message processing apparatus of claim 8, wherein based on a determination that the one data message feed port is in an inactive state, the processing circuitry is configured to halt adaptation of the data message processing latency time while the one of the data message feed ports remains in the inactive state.
14. An electronic data message processing apparatus comprising: gateway interface circuitry comprising data message feed ports comprising a first feed port and a second feed port and configured to receive source data messages from source entities, each source module having generated a respective chronological sequence of source data messages, where some of the source data messages received at the data message feed ports are received out of chronological sequence; and processing circuitry coupled to the gateway interface circuitry and configured to:
compare a next message time associated with one of the source data messages received from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port;
in response to the next message time for the source data message from the first feed port exceeding the current feed time for the latest processed source data message from the second feed port, (i) set the current feed time to the next message time and (ii) adapt a data message processing latency time;
order the source data messages received at ones of the data message feed ports in a chronological sequence of destination data messages; and
generate, within the adapted data message processing latency time, a combined data message stream that includes the chronological sequence of destination data messages; and transmit circuitry configured to transmit the combined data message stream to one or more destination entities.
9. Claim(s) 2-20 is/are rejected on the ground of nonstatutory double patenting as being unpatentable over claim(s) 1-19 of U.S. Patent 12,160,403. Although the claims at issue are not identical, they are not patentably distinct from each other because one of ordinary skill in the art would have known the current limitations in Claims 2-20 of the current application are disclosed in Patent 12,160,403 which includes extra features in the claim limitation and with windowing operations in Kafka Streams with specifying grace periods for out of order data records in order to change a feed port from an inactive to active state.
Claims 2-8, 12, and 15-19 of the instant application and claims 1-7, 8-12, and 14 of US Patent 12,160,403 are representative of the double patenting issue present.
Claims 2-20 (application 18/958,139)
Claims 1-19 (Patent 12,160,403)
2. An electronic data message processing apparatus comprising:
a first feed and a second feed each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
processing circuitry configured to:
compare a next message time associated with one of the source data messages from the first feed and waiting to be processed, to a current feed time of a latest processed source data message from the second feed; detect that the next message time exceeds the current feed time, and adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time; order the received source data messages in a chronological sequence of output data messages; and generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of output data messages; and circuitry configured to send the combined data message stream towards one or more data destinations, wherein the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to one of the first feed and the second feed changing to an active state within a predetermined recovery time period, and (b) process data messages in the combined data message stream out of chronological order in response to one of the first feed and the second feed changing to an active state outside of the predetermined recovery time period.
3. (New) The electronic data message processing apparatus of claim 2, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed.
4. (New) The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to process data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
5. (New) The electronic data message processing apparatus of claim 2, wherein the processing circuitry is further configured to adapt the latency time based on a difference between the next message time and the reference time.
6. (New) The electronic data message processing apparatus of claim 2, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and the second feed having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one of the data messages waiting to bc processed and read a next data message at that one data message feed.
7. (New) The electronic data message processing apparatus of claim 2, wherein based on a determination that the one of the first feed and the second feed is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first feed and the second feed remains in the inactive state.
8. (New) The electronic data message processing apparatus of claim 2, wherein each received data message includes a time stamp and the processing circuitry is configured to re- sequence, based on one or more time stamps, one or more data messages received out of sequence.
9. (New) The electronic data message processing apparatus of claim 2, wherein the adapted latency time corresponds to a difference between the current feed time and a reference time.
10. (New) The electronic data message processing apparatus of claim 2, wherein a reference time is later than the current feed time, and wherein the processing circuitry is further configured to maintain the reference time in response to a message being out of chronological message sequence.
11. (New) The electronic data message processing apparatus of claim 2, wherein: a reference time is later than the current feed time,
the one of the data messages waiting to be processed is a next data message currently received at one of the first feed and the second feed having a current earliest data message time, and
in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process that data message and read a next data message at that one data message feed.
12. (New) An electronic data message processing apparatus comprising:
a first feed and a second feed each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and
processing circuitry configured to:
compare a next message time associated with one of the source data messages from the first feed and waiting to be processed, to a current feed time of a latest processed source data message from the second feed;
detect that the next message time exceeds the current feed time and adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
order the received source data messages in a chronological sequence of output data messages; and
generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of output data messages; and
circuitry configured to send the combined data message stream towards one or more data destinations.
13. (New) The electronic data message processing apparatus of claim 12, wherein the latency time corresponds to a difference between the current feed time and a reference time.
14. (New) The electronic data message processing apparatus of claim 12, wherein the processing circuitry is further configured to adapt the latency time based on a difference between the next message time and the reference time, the reference time being later than the current feed time.
15. (New) The electronic data message processing apparatus of claim 12, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed.
16. (New) The electronic data message processing apparatus of claim 12, wherein the processing circuitry is further configured to process data messages in the combined data message stream and to detect data messages that are out of chronological message sequence based on a reference time that is later than the current feed time.
17. (New) The electronic data message processing apparatus of claim 12, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first feed and the second feed having a current earliest data message time, and wherein if the current earliest data message time is less than a reference time, then the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at the one of the first feed and the second feed.
18. (New) The electronic data message processing apparatus of claim 12, wherein based on a determination that the one of the first feed and the second feed is in an inactive state,
the processing circuitry is configured to halt adaptation of the latency time while the one of the first feed and the second feed remains in the inactive state.
19. (New) A method comprising:
receiving, at a first feed and a second feed, source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; comparing, by processing circuitry, a next message time associated with one of the source data messages from the first feed and waiting to be processed, to a current feed time of a latest processed source data message from the second feed;
detecting, by processing circuitry, that the next message time exceeds the current feed time and adapting a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time;
ordering, by the processing circuitry, the received source data messages in a chronological sequence of output data messages;
generating, by the processing circuitry, within the adapted latency time, a combined data message stream that includes the chronological sequence of output data messages; and sending the combined data message stream towards one or more data destinations.
20. (New) The method in claim 19, further comprising: processing, by the processing circuitry, data messages in the combined data message stream in chronological order in response to one of the first feed and the second feed changing to an active state within a predetermined recovery time period, and
processing, by the processing circuitry, data messages in the combined data message stream out of chronological order in response to one of the first feed and the second feed changing to an active state outside of the predetermined recovery time period.
1. An electronic data message processing apparatus comprising: a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and processing circuitry coupled to the first feed port and the second feed port and configured to: compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port; in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time; order the received source data messages in a chronological sequence of destination data messages; and generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and transmit circuitry configured to transmit the combined data message stream to one or more data destinations, wherein the processing circuitry is configured to (a) process data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and (b) process data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
2. The electronic data message processing apparatus of claim 1, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
3. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to process the data messages in the combined data message stream and to detect data messages that are out of chronological message sequence using the reference time.
4. The electronic data message processing apparatus of claim 1, wherein the processing circuitry is further configured to adapt the latency time based on a difference between the next message time and the reference time.
5. The electronic data message processing apparatus of claim 1, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at that one data message feed port.
6. The electronic data message processing apparatus of claim 1, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
7. The electronic data message processing apparatus of claim 1, wherein each received data message includes a time stamp and the processing circuitry is configured to re-sequence, based on one or more time stamps, one or more data messages received out of sequence.
8. The electronic data message processing apparatus of claim 1, wherein the adapted latency time corresponds to a difference between the current feed time and a reference time.
9. The electronic data message processing apparatus of claim 1, wherein a reference time is later than the current feed time, and wherein the processing circuitry is further configured to maintain the reference time in response to a message being out of chronological message sequence.
10. The electronic data message processing apparatus of claim 1, wherein: a reference time is later than the current feed time, the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and in response to the current earliest data message time being less than the reference time, the processing circuitry is configured to process that data message and read a next data message at that one data message feed port.
11. An electronic data message processing apparatus comprising: a first feed port and a second feed port each configured to receive source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; and processing circuitry coupled to the first feed port and the second feed port and configured to: compare a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port; in response to the next message time exceeding the current feed time, (i) set the current feed time to the next message time and (ii) adapt a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time; order the received source data messages in a chronological sequence of destination data messages; and generate, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and transmit circuitry configured to transmit the combined data message stream to one or more data destinations.
12. The electronic data message processing apparatus of claim 11, wherein the latency time corresponds to a difference between the current feed time and a reference time.
13. The electronic data message processing apparatus of claim 11, wherein the processing circuitry is further configured to adapt the latency time based on a difference between the next message time and the reference time, the reference time being later than the current feed time.
14. The electronic data message processing apparatus of claim 11, wherein the current feed time may be different from a time stamp for a latest processed data message from the second feed port.
15. The electronic data message processing apparatus of claim 11, wherein the processing circuitry is further configured to process data messages in the combined data message stream and to detect data messages that are out of chronological message sequence based on a reference time that is later than the current feed time.
16. The electronic data message processing apparatus of claim 11, wherein the one of the data messages waiting to be processed is a next data message currently received at one of the first and second feed ports having a current earliest data message time, and wherein if the current earliest data message time is less than a reference time, then the processing circuitry is configured to process the one of the data messages waiting to be processed and read a next data message at the one of the first and second feed ports.
17. The electronic data message processing apparatus of claim 11, wherein based on a determination that the one of the first and second feed ports is in an inactive state, the processing circuitry is configured to halt adaptation of the latency time while the one of the first and second feed ports remains in the inactive state.
18. A method comprising: receiving, at a first feed port and a second feed port, source data messages out of chronological sequence as compared to a generated sequence of at least some of the source data messages; comparing, by processing circuitry coupled to the first and second feed ports, a next message time associated with one of the source data messages from the first feed port and waiting to be processed, to a current feed time of a latest processed source data message from the second feed port; in response to the next message time exceeding the current feed time, the processing circuitry: (i) setting the current feed time to the next message time and (ii) adapting a latency time corresponding to a difference between the current feed time and a reference time to generate an adapted latency time; ordering, by the processing circuitry, the received source data messages in a chronological sequence of destination data messages; generating, by the processing circuitry, within the adapted latency time, a combined data message stream that includes the chronological sequence of destination data messages; and transmitting, by transmitting circuitry, the combined data message stream to one or more data destinations.
19. The method in claim 18, further comprising: processing, by the processing circuitry, data messages in the combined data message stream in chronological order in response to one of the first and second feed ports changing to an active state within a predetermined recovery time period, and processing, by the processing circuitry, data messages in the combined data message stream out of chronological order in response to one of the first feed port and the second feed port changing to an active state outside of the predetermined recovery time period.
Conclusion
9. Any inquiry concerning this communication or earlier communications from the examiner should be directed to HO T SHIU whose telephone number is (571)270-3810. The examiner can normally be reached Mon-Fri (9:00am - 5:00pm).
Examiner interviews are available via telephone, in-person, and video conferencing using a USPTO supplied web-based collaboration tool. To schedule an interview, applicant is encouraged to use the USPTO Automated Interview Request (AIR) at http://www.uspto.gov/interviewpractice.
If attempts to reach the examiner by telephone are unsuccessful, the examiner’s supervisor, Nicholas Taylor can be reached at 571-272-3089. The fax phone number for the organization where this application or proceeding is assigned is 571-273-8300.
Information regarding the status of published or unpublished applications may be obtained from Patent Center. Unpublished application information in Patent Center is available to registered users. To file and manage patent submissions in Patent Center, visit: https://patentcenter.uspto.gov. Visit https://www.uspto.gov/patents/apply/patent-center for more information about Patent Center and https://www.uspto.gov/patents/docx for information about filing in DOCX format. For additional questions, contact the Electronic Business Center (EBC) at 866-217-9197 (toll-free). If you would like assistance from a USPTO Customer Service Representative, call 800-786-9199 (IN USA OR CANADA) or 571-272-1000.
/HO T SHIU/Examiner, Art Unit 2443
HO T. SHIU
Examiner
Art Unit 2443
/NICHOLAS R TAYLOR/Supervisory Patent Examiner, Art Unit 2443
Prosecution Insights