Managing queues in an asynchronous messaging system
First Claim
1. A method of managing an asynchronous messaging queue with a client computer in an asynchronous messaging system, said client computer being programmed to store and manage said asynchronous messaging queue, said method comprising:
- receiving a reactive message in said asynchronous messaging queue stored by said client computer, said reactive message comprising a reactive message indicator that the reactive message is reactive, an identification of a previously initiated message and an action to be performed on said previously initiated message;
determining whether the previously initiated message is present in the same asynchronous message queue where the reactive message has been received prior to a final delivery of the previously initiated message to an intended recipient;
responsive to a determination that said previously initiated message is present in that asynchronous messaging queue prior to the final delivery of the previously initiated message to the intended recipient, performing said action specified by the reactive message on said previously initiated message with said client computer prior to final delivery of the previously initiated message to the intended recipient;
responsive to a determination that said previously initiated message has not already been received in said asynchronous messaging queue, storing said reactive message in a reactive message store for subsequent performance of said action on said previously initiated message when said previously initiated message is subsequently available in that asynchronous messaging queue; and
responsive to a determination that at least one reactive message stored in said reactive message store identifies a subsequent message received in said asynchronous messaging queue, performing an action on said subsequent message that is specified by that reactive message which identifies said subsequent message.
0 Assignments
0 Petitions
Accused Products
Abstract
A method of managing an asynchronous messaging queue with a client computer in an asynchronous messaging system, where the client computer is programmed to store an manage the asynchronous messaging queue, includes receiving a reactive message in the asynchronous messaging queue, the reactive message including an identification of a previously initiated message and an action to be performed on the previously initiated message; and upon determining that the previously initiated message has already been received in the asynchronous messaging queue, performing the action on the previously initiated message with the client computer.
-
Citations
17 Claims
-
1. A method of managing an asynchronous messaging queue with a client computer in an asynchronous messaging system, said client computer being programmed to store and manage said asynchronous messaging queue, said method comprising:
-
receiving a reactive message in said asynchronous messaging queue stored by said client computer, said reactive message comprising a reactive message indicator that the reactive message is reactive, an identification of a previously initiated message and an action to be performed on said previously initiated message; determining whether the previously initiated message is present in the same asynchronous message queue where the reactive message has been received prior to a final delivery of the previously initiated message to an intended recipient; responsive to a determination that said previously initiated message is present in that asynchronous messaging queue prior to the final delivery of the previously initiated message to the intended recipient, performing said action specified by the reactive message on said previously initiated message with said client computer prior to final delivery of the previously initiated message to the intended recipient; responsive to a determination that said previously initiated message has not already been received in said asynchronous messaging queue, storing said reactive message in a reactive message store for subsequent performance of said action on said previously initiated message when said previously initiated message is subsequently available in that asynchronous messaging queue; and responsive to a determination that at least one reactive message stored in said reactive message store identifies a subsequent message received in said asynchronous messaging queue, performing an action on said subsequent message that is specified by that reactive message which identifies said subsequent message. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 17)
-
-
10. An asynchronous messaging system node, said node comprising:
-
a processor; and computer memory communicatively coupled to and readable by said processor, said computer memory being configured to store an asynchronous messaging queue and software, such that said processor, when executing said software, is configured to; receive a reactive message in said asynchronous messaging queue, said reactive message comprising an identification of a previously initiated message and an action to be performed on said previously initiated message; search said asynchronous messaging queue to determine whether said previously initiated message has already been received in said asynchronous messaging queue; responsive to determining that said previously initiated message has already been received in said asynchronous messaging queue, perform said action on said previously initiated message prior to final delivery of the previously initiated message to an intended recipient; responsive to a determination that said previously initiated message has not already been received in said asynchronous messaging queue, storing said reactive message in a reactive message store for subsequent performance of said action on said previously initiated message; and responsive to a determination that at least one reactive message stored in said reactive message store identifies a subsequent message received in said asynchronous messaging queue, performing an action on said subsequent message specified by the at least one reactive message identifying said subsequent message. - View Dependent Claims (11, 12, 13, 14, 15)
-
-
16. A computer program product for managing an asynchronous messaging queue, the computer program product comprising:
-
a non-transitory computer readable storage medium having computer readable program code embodied therewith, the computer readable program code comprising; computer readable program code configured to receive a reactive message in said asynchronous messaging queue, said reactive message comprising an identification of a previously initiated message and an action to be performed on said previously initiated message; computer readable program code configured to perform said action on said previously initiated message responsive to a determination that said previously initiated message has already been received in said asynchronous messaging queue prior to a GET call to the asynchronous messaging queue from an application program that is the intended recipient of the previously initiated message; computer readable program code configured to store said reactive message in a reactive message store responsive to a determination that said previously initiated message has not already been received in said asynchronous messaging queue; and computer readable program code configured to perform said action on a subsequent message received in said asynchronous message queue in response to a determination that said reactive message stored in said reactive message store identifies said subsequent message.
-
Specification