Transaction message collector

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.

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.