TRANSACTION MESSAGE COLLECTOR
First Claim
1. A computer implemented method for data communication, the computer implemented method comprising:
- receiving, at a message collector, a message from a message producer;
storing the message in an active message bulk storage in the message collector, wherein the active message bulk storage is selected in correspondence to a message type of the message;
sending a confirmation from the message collector to the message producer via a result handler corresponding to the message type of the message, the confirmation informing the message producer that the message is stored in the active message bulk storage;
forwarding the active message bulk storage from the message collector to a message consumer, for consumption, if at least one of a plurality of time or memory based conditions is satisfied, the active message bulk storage being forwarded to the message consumer via an executor corresponding to a message type of the active message bulk storage;
receiving, at the message collector, a result of consumption of the active message bulk storage from the executor corresponding to the message type of the active message bulk storage; and
forwarding the result of consumption of the active message bulk storage from the message collector to the message producer via the result handler corresponding to the message type of the active message bulk storage.
2 Assignments
0 Petitions
Accused Products
Abstract
Various embodiments of systems and methods for a transaction message collector are described herein. The message collector receives the message from a message producer. In one aspect, the message is stored in an active message bulk storage or a new active message bulk storage. In another aspect, after the message is stored in the message collector, a confirmation is sent from the message collector to the message producer informing the message producer that the message is stored in the message collector. In yet another aspect, the active message bulk storage is forwarded to a message consumer for consumption based upon meeting at least one of plurality of time or memory based conditions. In a further aspect, after the active message bulk storage is consumed by the message consumer a result of consumption of the active message bulk storage is created and sent to the message producer.
-
Citations
30 Claims
-
1. A computer implemented method for data communication, the computer implemented method comprising:
-
receiving, at a message collector, a message from a message producer; storing the message in an active message bulk storage in the message collector, wherein the active message bulk storage is selected in correspondence to a message type of the message; sending a confirmation from the message collector to the message producer via a result handler corresponding to the message type of the message, the confirmation informing the message producer that the message is stored in the active message bulk storage; forwarding the active message bulk storage from the message collector to a message consumer, for consumption, if at least one of a plurality of time or memory based conditions is satisfied, the active message bulk storage being forwarded to the message consumer via an executor corresponding to a message type of the active message bulk storage; receiving, at the message collector, a result of consumption of the active message bulk storage from the executor corresponding to the message type of the active message bulk storage; and forwarding the result of consumption of the active message bulk storage from the message collector to the message producer via the result handler corresponding to the message type of the active message bulk storage. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. An article of manufacture including a computer readable storage medium to tangibly store instructions, which when executed by a computer, cause the computer to:
-
receive at a message collector, a message from a message producer; store the message in an active message bulk storage stored in the message collector, wherein the active message bulk storage is selected in correspondence to a message type of the message; send a confirmation from the message collector to the message producer, the confirmation informs the message producer that the message is stored in the active message bulk storage; forward the active message bulk storage from the message collector to a message consumer, for consumption, if at least one of a plurality of time or memory based conditions is satisfied, the active message bulk storage being forwarded to the message consumer via an executor corresponding to a message type of the active message bulk storage; receive, at the message collector, a result of consumption of the active message bulk storage from the executor corresponding to the message type of the active message bulk storage; and forward the result of consumption of the active message bulk storage from the message collector to the message producer via the result handler corresponding to the message type of the active message bulk storage. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
-
21. A computer system for implementing a process including a set of sub-tasks, the computer system comprising:
-
a memory to store program code; and a processor communicatively coupled to the memory, the processor to execute the program code, the program code comprising; a message producer to send a message to a message collector; the message collector to; store the message in an active message bulk storage corresponding to a message type of the message; send a confirmation to the message producer via a result handler corresponding to the message type of the message; forward the active message bulk storage to a message consumer, for consumption, if at least one of a plurality of time or memory based conditions is satisfied, the active message bulk storage being forwarded to the message consumer via an executor corresponding to a message type of the active message bulk storage; receive, from the executor corresponding to the message type of the active message bulk storage, a result of consumption of the active message bulk storage by the message consumer; and forward the result of consumption of the active message bulk storage to the message producer via the result handler corresponding to the message type of the active message bulk storage; and the message consumer to consume the active message bulk storage forwarded by the message collector. - View Dependent Claims (22, 23, 24, 25, 26, 27, 28, 29, 30)
-
Specification