OPTMISTIC PROCESSING OF MESSAGES IN A MESSAGING SYSTEM

• US 20070067313A1
• Filed: 09/14/2006
• Published: 03/22/2007
• Est. Priority Date: 09/17/2005
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Hobson, Stephen, Garza, Jose
• Granted Patent: US 9,442,781 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 2209/548 Queue
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

For processing messages in a messaging system comprising a source and a destination queue manager, an uncommitted message is received from an application at the source queue manager. This is transmitted to the destination queue manager and received thereat. When it is determined that the message is uncommitted, it is stored in memory, rather than placing the message on a receive queue for processing by another application. If it is determined that the uncommitted message has been committed by the application which originated the uncommitted message, then it is placed on the receive queue.

Claims

1. A method for a queue manager to process messages optimistically, the method comprising:

receiving an uncommitted message from a source queue manager, the uncommitted message forming part of a transaction;

responsive to determining that the queue manager is a destination queue manager and that the message is uncommitted, storing the message in memory; and

responsive to a determination that the uncommitted message has been committed by the application which originated the message, placing the transaction'"'"'s messages on a receive queue for processing therefrom.

2. The method of claim 1, comprising:

receiving an indication that the message is uncommitted from the source queue manager.

3. The method of claim 1, comprising:

determining from the message itself that the message is uncommitted.

4. The method of claim 1, wherein storing the message in memory comprises:

determining whether other messages in the transaction are known about by the destination queue manager; and

responsive to a positive determination, adding the received messages to a list of the other messages.

5. The method of claim 1, comprising:

receiving, at the destination queue manager, an indication that a transaction including the received message is to be undone; and

deleting the transaction from memory.

6. The method of claim 1, comprising:

deleting old messages from memory in order to free up space for newly received messages at the destination queue manager;

receiving notification that a deleted message has been committed; and

requesting retransmission of the deleted message by the source queue manager.

7. The method of claim 1, comprising;

receiving the uncommitted message at an intermediate queue manager;

forwarding the message as an uncommitted message on its way to the destination queue manager unless a transmission path is unavailable; and

responsive to a transmission path being unavailable, storing the uncommitted message in memory associated with the intermediate queue manager.

8. The method of claim 1, comprising:

responsive to determining that the queue manager is an intermediate queue manager, forwarding the message as an uncommitted message on its way to the destination queue manager unless a transmission path is unavailable; and

responsive to a transmission path being unavailable, storing the uncommitted message in memory associated with the intermediate queue manager.

9. Apparatus for a queue manager to process messages optimistically, the apparatus comprising:

means for receiving an uncommitted message from a source queue manager, the uncommitted message forming part of a transaction;

means, responsive to determining that the queue manager is a destination queue manager and that the message is uncommitted, for storing the message in memory; and

means, responsive to a determination that the uncommitted message has been committed by the application which originated the message, for placing the transaction'"'"'s messages on a receive queue for processing therefrom.

10. The apparatus of claim 9, comprising:

means for deleting old messages from memory in order to free up space for newly received messages at the destination queue manager;

means for receiving notification that a deleted message has been committed; and

means for requesting retransmission of the deleted message by the source queue manager.

11. A computer program product for a queue manager to process messages optimistically, the computer program product comprising a computer readable medium having computer readable program code tangibly embedded therein, the computer readable program code comprising:

computer readable program code configured to receive an uncommitted message from a source queue manager, the uncommitted message forming part of a transaction;

computer readable program code configured to, responsive to determining that the queue manager is a destination queue manager and that the message is uncommitted, store the message in memory; and

computer readable program code configured to, responsive to a determination that the uncommitted message has been committed by the application which originated the message, place the transaction'"'"'s messages on a receive queue for processing therefrom.

12. The computer program product of claim 11, comprising:

computer readable program code configured to receive an indication that the message is uncommitted from the source queue manager.

13. The computer program product of claim 11, comprising:

computer readable program code configured to determine from the message itself that the message is uncommitted.

14. The computer program product of claim 11, wherein the computer readable program code configured to store the message in memory comprises:

computer readable program code configured to determine whether other messages in the transaction are known about by the destination queue manager; and

computer readable program code configured to, responsive to a positive determination, add the received messages to a list of the other messages.

15. The computer program product of claim 11, comprising:

computer readable program code configured to receive, at the destination queue manager, an indication that a transaction including the received message is to be undone; and

computer readable program code configured to delete the transaction from memory.

16. The computer program product of claim 11, comprising:

computer readable program code configured to delete old messages from memory in order to free up space for newly received messages at the destination queue manager,

computer readable program code configured to receive notification that a deleted message has been committed; and

computer readable program code configured to request retransmission of the deleted message by the source queue manager.

17. The computer program product of claim 11, comprising:

computer readable program code configured to receive the uncommitted message at an intermediate queue manager;

computer readable program code configured to forward the message as an uncommitted message on its way to the destination queue manager unless a transmission path is unavailable; and

computer readable program code configured to, responsive to a transmission path being unavailable, store the uncommitted message in memory associated with the intermediate queue manager.

18. The computer program product of claim 11, comprising:

computer readable program code configured to, responsive to determining that the queue manager is an intermediate queue manager, forward the message as an uncommitted message on its way to the destination queue manager unless a transmission path is unavailable; and

computer readable program code configured to, responsive to a transmission path being unavailable, store the uncommitted message in memory associated with the intermediate queue manager.