Method and system for implementing a best efforts resequencer

• US 9,124,448 B2
• Filed: 04/04/2009
• Issued: 09/01/2015
• Est. Priority Date: 04/04/2009
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Singh, Atul, Joshi, Maneesh, Patel, Ashwin, Garimella, Annaji Rao
• Primary Examiner(s): Shah, Chirag
• Assistant Examiner(s): YOUNG, STEVE R
• Application Number:
  US12/418,585
• Publication Number:
  US 20100254389A1
• Time in Patent Office: 2,341 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: H04L 51/234 for tracking messages

Abstract

Described is an improved method, system, and computer program product for implementing an improved resequencer, along with related mechanisms and processes. A best efforts resequencing approach is described for determining a set of messages to process in a computing system.

Claims

1. A method for determining a set of messages to process in a computing system, comprising:

receiving a set of messages from a message producer;

establishing a waiting period for the set of messages to be processed, wherein the set of messages are sequenced using a set of non-contiguous sequence identifiers such that it is unknown whether any messages are missing from the set of messages based on the set of non-contiguous sequence identifiers;

using a processor to determine whether any messages of the set of messages arrive over a network to be processed during a pendency of the waiting period for the set of messages;

re-starting the waiting period to wait for new messages if any messages of the set of messages arrive during the pendency of the waiting period˜

wherein the waiting period is restarted for an arriving message even if it is unknown whether any messages of the set of messages are missing based on a non-contiguous sequence identifier of the arriving message;

extending the waiting period if a first message arrives during the pendency of the waiting period that indicates that a second message is missing, wherein the indication that the second message is missing is based at least in part on text-based sequence information in the first message; and

selecting all existing messages for the set of messages to be processed by the computing system if there are no new messages that arrive during the pendency of the waiting period.

2. The method of claim 1 in which the existing messages are sorted based on the non-contiguous sequence identifier.

3. The method of claim 1 which is implemented using a resequencer.

4. The method of claim 1 in which the waiting period is extended.

5. The method of claim 1, wherein the set of messages comprises a plurality of groups, wherein the messages are sorted for different consumers based at least in part upon the non-contiguous sequence identifier and a group identifier.

6. A computer program product that includes a non-transitory computer readable medium, the computer readable medium comprising a plurality of computer instructions which, when executed by a processor, cause the processor to execute a process for determining a set of messages to process in a computing system, the process comprising:

receiving a set of messages from a message producer;

establishing a waiting period for the set of messages to be processed, wherein the set of messages are sequenced using a set of non-contiguous sequence identifiers such that it is unknown whether any messages are missing from the set of messages based on the set of non-contiguous sequence identifiers;

using a processor to determine whether any messages of the set of messages arrive over a network to be processed during a pendency of the waiting period for the set of messages;

re-starting the waiting period to wait for new messages if any messages of the set of messages arrive during the pendency of the waiting period wherein the waiting period is restarted for an arriving message even if it is unknown whether any messages of the set of messages are missing based on a non-contiguous sequence identifier of the arriving message;

extending the waiting period if a first message arrives during the pendency of the waiting period that indicates that a second message is missing, wherein the indication that the second message is missing is based at least in part on text-based sequence information in the first message; and

selecting all existing messages for the set of messages to be processed by the computing system if there are no new messages that arrive during the pendency of the waiting period.

7. The computer program product of claim 6 in which the existing messages are sorted based on the non-contiguous sequence identifier.

8. The computer program product of claim 6 which is implemented using a resequencer.

9. The computer program product of claim 6 in which the waiting period is extended.

10. The computer program product of claim 6, wherein the set of messages comprises a plurality of groups, wherein the messages are sorted for different consumers based at least in part upon the non-contiguous sequence identifier and a group identifier.

11. A system for determining a set of messages to process in a computing system, comprising:

means for receiving a set of messages from a message producer

means for establishing a waiting period for the set of messages to be processed by a computing system, wherein the set of messages are sequenced using a set of non-contiguous sequence identifiers such that it is unknown whether any messages are missing from the set of messages based on the set of non-contiguous sequence identifiers;

means for using a processor to determine whether any messages of the set of messages arrive over a network to be processed during a pendency of the waiting period for the set of messages;

means for re-starting the waiting period to wait for new messages if any messages of the set of messages arrive during the pendency of the waiting period, wherein the waiting period is restarted for an arriving message even if it is unknown whether any messages of the set of messages are missing based on a non-contiguous sequence identifier of the arriving message;

means for extending the waiting period if a first message arrives during the pendency of the waiting period that indicates that a second message is missing, wherein the indication that the second message is missing is based at least in part on text-based sequence information in the first message; and

means for selecting the existing messages for the set of messages to be processed by the computing system if there are no new messages that arrive during the pendency of the waiting period.

12. The system of claim 11 in which the existing messages are sorted based on the non-contiguous sequence identifier.

13. The system of claim 11 in which the system is implemented as a resequencer.

14. The system of claim 11 in which the waiting period is extended.

15. The system of claim 14, wherein the set of messages comprises a plurality of groups, wherein the messages are sorted for different consumers based at least in part upon the non-contiguous sequence identifier and a group identifier.

16. A method for determining a set of messages to process in a computing system, comprising:

receiving a set of messages from a message producer;

establishing a waiting period for a plurality of groups of messages to be processed by a computing system, wherein the waiting period is established on a per group basis, and wherein a group of messages of the plurality of groups of messages are sequenced using a set of non-contiguous sequence of identifiers such that it is unknown whether any messages are missing from the group of messages based on the set of non-contiguous sequence identifiers;

for the group of messages;

using a processor to determine whether any messages of the group arrive over a network to be processed during a pendency of the waiting period;

re-starting the waiting period to wait for new messages if any messages of the group of messages arrive during the pendency of the waiting period, wherein the waiting period is restarted for an arriving message even if it is unknown whether any messages of the group of messages are missing based on a non-contiguous sequence identifier of the arriving message;

extending the waiting period if a first message arrives during the pendency of the waiting period that indicates that a second message is missing, wherein the indication that the second message is missing is based at least in part on text-based sequence information in the first message; and

selecting all existing messages for the group to be processed by the computing system if there are no new messages for the group that arrive during the pendency of the waiting period.

17. The method of claim 16 which is implemented using a resequencer.

18. The method of claim 16 in which the waiting period is extended.

19. A computer program product that includes a non-transitory computer readable medium, the computer readable medium comprising a plurality of computer instructions which, when executed by a processor, cause the processor to execute a process for determining a set of messages to process in a computing system, the process comprising:

receiving a set of messages from a message producer;

establishing a waiting period for a plurality of groups of messages to be processed by a computing system, wherein the waiting period is established on a per group basis, and wherein group of messages of the plurality of groups of messages are sequenced using a set of non-contiguous sequence of identifiers such that it is unknown whether any messages are missing from the group of messages based on the set of non-contiguous sequence identifiers;

for the group of messages;

using a processor to determine whether any messages of the group arrive over a network to be processed during a pendency of the waiting period;

re-starting the waiting period to wait for new messages if any messages of the group of messages arrive during the pendency of the waiting period, wherein the waiting period is restarted for an arriving message even if it is unknown whether any messages of the set of messages are missing based on a non-contiguous sequence identifier of the arriving message;

extending the waiting period if a first message arrives during the pendency of the waiting period that indicates that a second message is missing, wherein the indication that the second message is missing is based at least in part on text-based sequence information in the first message; and

selecting all existing messages for the group to be processed by the computing system if there are no new messages for the group that arrive during the pendency of the waiting period.

20. The computer program product of claim 19 which is implemented using a resequencer.

21. The computer program product of claim 19 in which the waiting period is extended.

22. A system for determining a set of messages to process in a computing system, comprising:

a processor programmed for;

receiving a set of messages from a message producer;

establishing a waiting period for a plurality of groups of messages to be processed by a computing system, wherein the waiting period is established on a per group basis, and wherein group of messages of the plurality of groups of messages are sequenced using a set of non-contiguous sequence of identifiers such that it is unknown whether any messages are missing from the group of messages based on the set of non-contiguous sequence identifiers;

for the group of messages;

using a processor to determine whether any messages of the group arrive over a network to be processed during a pendency of the waiting period;

re-starting the waiting period to wait for new messages if any messages of the group of messages arrive during a pendency of the waiting period, wherein the waiting period is restarted for an arriving message even if it is unknown whether any messages of the set of messages are missing based on a non-contiguous sequence identifier of the arriving message;

extending the waiting period if a first message arrives during the pendency of the waiting period that indicates that a second message is missing, wherein the indication that the second message is missing is based at least in part on text-based sequence information in the first message; and

selecting all existing messages for the group to be processed by the computing system if there are no new messages for the group that arrive during the pendency of the waiting period.

23. The system of claim 22 in which the system is implemented as a resequencer.

24. The system of claim 22 in which the waiting period is extended.