System and method for generating exception delay messages when messages are delayed

• US 8,055,782 B2
• Filed: 10/13/2008
• Issued: 11/08/2011
• Est. Priority Date: 10/13/2008
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Hickson, Andrew, Emmett, Andrew Anthony, Goddard, Nigel, Akehurst, Andrew David
• Primary Examiner(s): Hoang; Hieu
• Application Number:
  US12/250,429
• Publication Number:
  US 20100094933A1
• Time in Patent Office: 1,121 Days
• Field of Search: 709/223, 709/224, 709/230
• US Class Current: 709/230
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling

Abstract

Generating exception delay messages when messages communicated between asynchronous messaging applications are delayed and for forcibly retaining the original message. Specifically, the invention provides methods and systems for generating an exception delay message after a time threshold has expired without deleting the original message. The exception delay message may be sent once when the time threshold first expires or each time that the time threshold expires.

Claims

1. A method for processing of delayed messages, the method comprising the steps of:

putting, by a computer, a first message in a first message queue managed by a first message queue manager, the first message comprising a time threshold data item comprising a delay time interval;

setting the delay time interval to an initial time value;

decrementing, by the first message queue manager, the delay time interval while the first message awaits processing in the first message queue;

determining, by the first message queue manager, whether the decremented delay time interval has expired and the first message is not processed by the first message queue manager;

in response to determining that the decremented delay time interval has expired and the first message is not processed by the first message queue manager;

generating, by the first message queue manager, a second message, wherein the second message indicates that the decremented delay time interval has expired;

notifying an entity at a specified destination that the decremented delay time interval has expired and the first message is not processed by the first message queue manager by sending the second message to the specified destination;

retaining the first message in the first message queue until the first message is processed by the first message queue manager;

sending the first message from the first message queue to a second message queue managed by a second message queue manager, the first message comprising the decremented delay time interval;

further decrementing, by the second message queue manager, the decremented delay time interval while the first message awaits processing in the second message queue;

determining, by the second message queue manager, whether the decremented delay time interval has expired and the first message is not processed by the second message queue manager;

generating, by the second message queue manager, in response to determining that the decremented delay time interval has expired and the first message is not processed by the second message queue manager, a third message;

notifying the entity that the decremented delay time interval has expired and the first message is not processed by the second message queue manager by sending the third message to the specified destination; and

retaining the first message in the second message queue until the first message is processed by the second message queue manager.

2. The method claim 1, wherein the amount of time before the decremented delay time interval expires is passed within the first message to the second message queue manager when the first message in transferred from the first message queue manager to the second message queue manager.

3. The method of claim 1, further comprising:

resetting the decremented delay time interval to the initial time value each time that the decremented delay time interval expires; and

generating the second message each time that the decremented delay time interval expires.

4. The method of claim 1, further comprising sending the second message to a message queue of a target node for the first message.

5. The method of claim 1, further comprising sending the third message to the first message queue manager.

6. A computer program product for processing of delayed messages, the computer program product comprising:

a non-transitory computer-readable storage medium having computer-readable program code embodied therein, the computer-readable program code for;

putting a first message in a first message queue, the first message comprising a time threshold data item comprising a delay time interval;

setting the delay time interval to an initial time value;

decrementing the delay time interval while the first message awaits processing in the first message queue;

determining whether the decremented delay time interval has expired and the first message is not processed in the first message queue;

generating, in response to determining that the time interval has expired and the first message is not processed in the first message queue, a second message, wherein the second message indicates that the time interval has expired;

notifying an entity at a specified destination that the decremented delay time interval has expired and the first message is not processed in the first message queue by sending the second message to the specified destination; and

retaining, in response to determining that the time interval has expired, the first message in the first message queue until the first message is processed in the first message queue;

sending the first message from the first message queue to a second message queue, the first message comprising the decremented delay time interval;

further decrementing the decremented delay time interval while the first message awaits processing in the second message queue;

determining whether the decremented delay time interval has expired and the first message is not processed in the second message queue;

generating, in response to determining that the decremented delay time interval has expired and the first message is not processed in the second message queue, a third message;

notifying the entity that the decremented delay time interval has expired and the first message is not processed in the second message queue by sending the third message to the specified destination; and

retaining the first message in the second message queue until the first message is processed in the second message queue.

7. The computer program product claim 6, wherein the amount of time before the decremented delay time interval expires is passed within the first message to the second message queue when the first message in transferred from the first message queue to the second message queue.

8. The computer program product of claim 6, wherein the computer-readable program code is further for:

resetting the decremented delay time interval to the initial time value each time that the decremented delay time interval expires; and

generating the second message each time that the decremented delay time interval expires.

9. The computer program product of claim 6, wherein the computer-readable program code is further for sending the second message to a message queue of a target node for the first message.