METHOD ,SYSTEM AND COMPUTER PROGRAM PRODUCT FOR SEQUENCING ASYNCHRONOUS MESSAGES IN A DISTRIBUTED AND PARALLEL ENVIRONMENT

摘要

The invention provides a system and a computer- implemented method of sequencing distributed asynchronous messages in a distributed and parallel system having a plurality of inbound handlers forming an inbound handlers layer and a plurality of outbound handlers forming an outbound handlers layer , the method comprising the following steps performed with at least one data processor: receiving in any inbound handler out of the plurality of inbound handlers an incoming message the incoming message comprising a sequence correlation value that identifies a sequence comprising the incoming message , checking for a sequence status of said sequence in a shared sequence storage; determining if the incoming message is the next message to be processed for maintaining the order of the messages in said sequence; -if the sequence status indicates that none of the outbound handlers in the outbound handlers layer is currently processing a message for said sequence and if the incoming message is determined to be the next message to be processed for said sequence , then forwarding the incoming message to a shared queue storage and subsequently retrieving the message by an available outbound handler in the outbound handlers layer for processing; - if the sequence status indicates that at least one of the outbound handlers in the outbound handlers layer is currently processing a message of said sequence; or if the shared queue storage already comprises a message to be processed for said sequence; or if the incoming message is determined not to be the next message to be processed for said sequence, then storing the incoming message in a memory of a shared overflow storage to keep for further processing.