Patent ID: 8635342

Claim:
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, when at least one of a plurality of time and 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, wherein the time and memory based conditions comprises: determining, by a processor of a computer, whether memory size of the active message bulk storage is greater than or equal to, a preset memory size of the active message bulk storage size, and memory size of the message collector; determining, by the processor of the computer, whether time elapsed for the message to be stored in the active message bulk storage is greater than or equal to a preset timeout period; and determining, by the processor of the computer, whether a number of the active message bulk storage stored in the message collector is greater than or equal to a preset maximum number of 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.