Method and apparatus for parallel sequencing of messages between disparate information systems

A method for coordinating concurrent processing of a plurality of messages communicated over a network between a source system and a target system, the plurality of messages configured for including a pair of related messages having a common first unique message identifier and at least one unrelated message having a second unique message identifier different from the first unique identifier, the method comprising the steps of:

• receiving the plurality of messages;
• identifying which of the plurality of messages are the pair of related messages and which of the plurality of messages are the at least one unrelated message using the first and second unique identifiers;
• identifying a sequence order for the pair of related messages according to a respective sequence indicator associated with each of the related messages, the sequence indicators configured for use in assigning a first position in the sequence order for a first message of the pair of related messages and for use in assigning a second position in the sequence order for a second message of the pair of related messages, such that the first message having a higher priority sequence indicator than the sequence indicator of the second message;
• monitoring the processing of the pair of related messages and the at least one unrelated message in an output message queue by inhibiting processing of the second message until a pending message status indicator for the first message is cleared while facilitating concurrent processing of the at least one unrelated message though the output message queue, the pending message status indicator for indicating that the first message is resident in the message output queue, the output message queue including a plurality of execution streams for facilitating concurrent processing of the at least one unrelated message with at least one of the pair of related messages when resident in the output message queue.

A computer program product having instructions stored on a non-transitory storage and configured for execution by a computer processor to coordinate concurrent processing of a plurality of messages communicated over a network between a source system and a target system, the plurality of messages configured for including a pair of related messages having a common first unique message identifier and at least one unrelated message having a second unique message identifier different from the first unique identifier, the instruction executable by a computer processor, the instructions comprising:

• storing of the plurality of messages in an input queue when received;
• storing of the plurality of messages in an output message queue during message processing, the output message queue for providing a plurality of execution streams for facilitating concurrent processing of the at least one unrelated message with at least one of the pair of related messages;
• determining using the first and second unique identifiers which of the plurality of messages are the pair of related messages and which of the plurality of messages are the at least one unrelated message;
• identifying a sequence order for the pair of related messages according to a respective sequence indicator associated with each of the related messages, the sequence indicators configured for use in assigning a first position in the sequence order for a first message of the pair of related messages and for use in assigning a second position in the sequence order for a second message of the pair of related messages, such that the first message having a higher priority sequence indicator than the sequence indicator of the second message;
• and
• storing a pending message status indicator in a registry for the first message, when the first message is in an output message queue;
• wherein the progression of processing through the output message queue is inhibited for the second message until the pending message status for the first message is removed from the registry while facilitating concurrent processing of the at least one unrelated message though the output message queue.