Method and system for performing blocking of messages on errors in message stream

• US 8,254,391 B2
• Filed: 04/04/2009
• Issued: 08/28/2012
• 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, Saha, Rakesh
• Primary Examiner(s): Yao, Kwang B
• Assistant Examiner(s): NGUYEN, ANH NGOC M
• Application Number:
  US12/418,583
• Publication Number:
  US 20100254259A1
• Time in Patent Office: 1,242 Days
• Field of Search: 370/394, 370/229, 370/230, 370/235, 370/390, 370/238, 370/241, 370/351, 370/392, 370/389, 370/242, 370/252
• US Class Current: 370/394
• CPC Class Codes: G06F 11/1443 Transmit or communication errors

Abstract

Described is an improved method, system, and computer program product for implementing an improved resequencer, along with related mechanisms and processes. An improved error handling method and system for messages is also described.

Claims

1. A computer implemented method for handling errors related to messages in a computing system, comprising:

using at least one processor that is programmed or configured for performing a process, the process comprising;

dividing a stream of messages into a first substream for a first destination and a second substream for a second destination;

determining whether an error for delivery or an error associated with delivery of a message from the first substream is detected before delivery of the message;

holding further delivery of messages from the first substream to the first destination if the error for delivery or the error associated with delivery of the message from the first substream is detected such that the first destination no longer receives the delivery of messages until a condition is satisfied; and

continuing to deliver messages for the second substream even after holding further delivery of the messages for the first substream.

2. The computer implemented method of claim 1, further comprising performing error handling to correct the error.

3. The computer implemented method of claim 2, in which delivery of the messages from the first substream is re-started after the error is corrected.

4. The computer implemented method of claim 1, in which the first substream and the second substream are sequenced and delivered by a resequencer.

5. The computer implemented method of claim 1, in which the error comprises machine failure, routing failure, or message corruption.

6. The computer implemented method of claim 1, in which the stream of messages are divided into the first substream and the second substream based at least in part upon group identifier information, wherein the message comprises a message payload and a message header, and the group information is located in the message payload.

7. The computer implemented method of claim 6, in which the group information is stored as one or more fields in the message payload.

8. The computer implemented method of claim 6, in which the group information is stored as a node or field in an XML document, wherein the node or field is accessible with an or XQuery expression.

9. A computer program product that includes a non-transitory computer readable storage medium, the non-transitory computer readable storage medium having stored thereupon a plurality of computer instructions which, when executed by at least one processor, cause the at least one processor to execute a process for handling errors related to messages in a computing system, the process comprising:

dividing a stream of messages into a first substream for a first destination and a second substream for a second destination;

determining whether an error for delivery or an error associated with delivery of a message from the first substream is detected before delivery of the message;

holding further delivery of messages from the first substream to the first destination if the error associated with delivery of the message from the first substream is detected such that the first destination no longer receives the delivery of messages until a condition is satisfied; and

continuing to deliver the messages for the second sub stream even after holding further delivery of the messages for the first substream.

10. The computer program product of claim 9, the process further comprising performing error handling to correct the error.

11. The computer program product of claim 10 in which delivery of the messages from the first substream is re-started after the error is corrected.

12. The computer program product of claim 9 in which the first substream and the second substream are sequenced and delivered by a resequencer.

13. The computer program product of claim 9 in which the error comprises machine failure, routing failure, or message corruption.

14. The computer program product of claim 9 in which the stream of messages are divided into the first substream and the second substream based upon group identifier information, wherein the message comprises a message payload and a message header and the group information is located in the message payload.

15. The computer program product of claim 14 in which the group information is stored as one or more fields in the message payload.

16. The computer program product of claim 14 in which the group information is stored as a node or field in an XML document, wherein the node or field is accessible with an XPath or XQuery expression.

17. A system for handling errors related to messages in a computing system, comprising:

a processor;

a memory for holding programmable code; and

wherein the programmable code includes instructions executable by the processor for;

dividing a stream of messages into a first substream for a first destination and a second substream for a second destination;

determining whether an error for delivery or an error associated with delivery of a message from the first substream is detected before delivery of the message;

holding further delivery of messages from the first substream to the first destination if the error associated with delivery of the message from the first substream is detected; and

continuing to deliver the messages for the second substream even after holding further delivery of the messages for the first substream.

18. The system of claim 17, the process further comprising performing error handling to correct the error.

19. The system of claim 18 in which delivery of the messages from the first substream is re-started after the error is corrected.

20. The system of claim 17 in which the first substream and the second substream are sequenced and delivered by a resequencer.

21. The system of claim 17 in which the error comprises machine failure, routing failure, or message corruption.

22. The system of claim 17 in which the stream of messages are divided into the first substream and the second substream based upon group identifier information, wherein the message comprises a message payload and a message header and the group information is located in the message payload.

23. The system of claim 22 in which the group information is stored as one or more fields in the message payload.

24. The system of claim 22 in which the group information is stored as a node or field in an XML document, wherein the node or field is accessible with an XPath or XQuery expression.