HANDLING OF MESSAGES IN A MESSAGE SYSTEM

• US 20130191680A1
• Filed: 03/11/2013
• Published: 07/25/2013
• Est. Priority Date: 10/14/2008
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Freund, Thomas J., Robinson, Ian
• Granted Patent: US 8,726,079 B2
• Time in Patent Office: Days
• US Class Current: 714/2
• CPC Class Codes: G06F 11/1443 Transmit or communication errors
• CPC Class Codes: G06F 11/1474 in transactions G06F16/20 takes precedence
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 51/23 Reliability checks, e.g. acknowledgments or fault reporting

Abstract

A messaging system comprises a message source, a message receiver and a message service. The message service is intermediate of the message source and message receiver, and a compensation component is established at the message source. A one way message is transmitted from the message source, where the one-way message is part of a plurality of one way messages of an overall business transaction. The message is received at the message service and is transmitted to the message receiver, which processes the received message. The message receiver transmits a communication indicating success or failure of the processing of the message. The system causes compensation logic defined by a compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction despite the communication from the message receiver indicated that processing of the particular one way message succeeded.

Claims

1. A computer readable storage medium having computer readable program code stored thereon, wherein the program code is executed to handle messages in a messaging system, comprising:

receiving, by a message service, a particular one-way message that was transmitted by a message source as part of an overall business transaction comprising a plurality of one-way messages;

communicating the particular one way message from the messaging service to a message receiver;

receiving, by the message service, a communication indicating success or failure of the processing of the particular one way message by the message receiver; and

causing compensation logic defined by a compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction despite the communication from the message receiver indicated that processing of the particular one way message succeeded.

2. The computer readable storage medium of claim 1 further comprising:

implementing the overall business transaction as a loosely coupled interaction between the message service and the message receiver that is longer-running in duration than a client, such that the overall business transaction is initiated on the client'"'"'s behalf.

3. The computer readable storage medium of claim 1 further comprising:

processing the overall business transaction using nested transaction relationships in which individual unshared transactions are child participants in a single distributed, shared parent transaction.

4. The computer readable storage medium of claim 3 further comprising providing successfully completed nested child transactions with an associated compensating action that is driven in the event of an unsuccessful outcome of the overall business transaction.

5. The computer readable storage medium of claim 3 further comprising propagating context from a parent transaction to immediate children of the corresponding parent transaction.

6. The computer readable storage medium of claim 1 further comprising generating a transaction protocol message comprising a completion message that determines that messages have been delivered to and successfully executed by the message receiver.

7. The computer readable storage medium of claim 1 further comprising providing a first queue and a second queue;

wherein;

receiving, by a message service, a particular one-way message comprises receiving the particular one way message at the first queue such that the compensation logic defined by the compensation component is added to a message activity if the particular one way message is successfully received into the first queue; and

communicating the particular one way message from the messaging service to a message receiver comprises creating a second message as a child-participant of the particular one way message, which is placed in the second queue and reading, by the message receiver, the child-participant of the particular one way message from the second queue.

8. The computer readable storage medium of claim 7, wherein:

receiving, by the message service, a communication indicating success or failure of the processing of the particular one way message comprises sending a completed message to the child-participant in the second queue indicating success, which causes the child-participant in the second queue to send a completed message to the particular one way message in the first queue;

further comprising;

sending the compensation logic and the child-participant a close message to clean up the now completed sequence.

9. The computer readable storage medium of claim 8, wherein causing compensation logic defined by the compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction when the communication indicated that processing of the particular one way message succeeded comprises detecting that the overall business transaction, comprises:

detecting that a second one-way message of the overall business transaction failed, which is being processed in parallel to the particular one-way message; and

driving the compensation logic and the child-participant to compensate.

10. The computer readable storage medium of claim 7, wherein:

receiving, by the message service, a communication indicating success or failure of the processing of the particular one way message by the message receiver comprises sending a completed message to the child-participant in the second queue indicating failure; and

causing compensation logic defined by the compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction despite the communication indicated that processing of the particular one way message succeeded, comprises executing the compensation logic added to a message activity and putting a compensation message in the second queue that instructs the message receiver to compensate actions of the message receiver on forward processing.

11. A computer readable storage medium having computer readable program code stored thereon, wherein the program code is executed to handle messages in a messaging system, comprising:

transmitting a particular one way message, as part of an overall business transaction, from a message source, the overall business transaction comprising a plurality of one way messages;

receiving the particular one way message at a message service;

transmitting the particular one way message from the messaging service;

receiving the particular one way message at a message receiver;

processing the particular one way message at the message receiver;

transmitting a communication from the message receiver, the communication indicating success or failure of the processing of the particular one way message;

receiving the communication at the messaging service; and

causing compensation logic defined by the compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction when the communication indicated that processing of the particular one way message succeeded.

12. The computer readable storage medium of claim 11 further comprising:

implementing the message source as a first server and implementing the message receiver as a second server as part of a back-end system of a website.

13. The computer readable storage medium of claim 11 further comprising:

processing the overall business transaction using nested transaction relationships in which individual unshared transactions are child participants in a single distributed, shared parent transaction.

14. The computer readable storage medium of claim 13 further comprising providing successfully completed nested child transactions with an associated compensating action that is driven in the event of an unsuccessful outcome of the overall business transaction.

15. The computer readable storage medium of claim 13 further comprising propagating context from a parent transaction to immediate children of the corresponding parent transaction.

16. The computer readable storage medium of claim 11 further comprising generating a transaction protocol message comprising a completion message that determines that messages have been delivered to and successfully executed by the message receiver.

17. The computer readable storage medium of claim 11 further comprising providing a first queue and a second queue;

wherein;

receiving the particular one way message at a message service comprises receiving the particular one way message at the first queue such that the compensation logic defined by the compensation component is added to a message activity if the particular one way message is successfully received into the first queue; and

receiving the particular one way message at a message receiver comprises creating a second message as a child-participant of the particular one way message, which is placed in the second queue and reading, by the message receiver, the child-participant of the particular one way message from the second queue.

18. The computer readable storage medium of claim 17, wherein:

transmitting a communication from the message receiver, the communication indicating success or failure of the processing of the particular one way message comprises sending a completed message to the child-participant in the second queue indicating success, which causes the child-participant in the second queue to send a completed message to the particular one way message in the first queue;

further comprising;

sending the compensation logic and the child-participant a close message to clean up the now completed sequence.

19. The computer readable storage medium of claim 18, wherein causing compensation logic defined by the compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction when the communication indicated that processing of the particular one way message succeeded comprises detecting that the overall business transaction, comprises:

detecting that a second one-way message of the overall business transaction failed, which is being processed in parallel to the particular one-way message; and

driving the compensation logic and the child-participant to compensate.

20. The computer readable storage medium of claim 17, wherein:

transmitting a communication from the message receiver, the communication indicating success or failure of the processing of the particular one way message comprises sending a completed message to the child-participant in the second queue indicating failure; and

causing compensation logic defined by the compensation component to execute responsive to receiving an indication of a failure of part of the overall business transaction despite the communication indicated that processing of the particular one way message succeeded, comprises executing the compensation logic added to a message activity and putting a compensation message in the second queue that instructs the message receiver to compensate actions of the message receiver on forward processing.