Message processing
OwnerAntoni N. Drudis, Bill Serrainventors
Life of this patent
Estimating the term…
Abstract
In distributed processing systems the distribution of messages from a message queue to the multiple processing devices is generally managed either by a queue manager or directly by each processing device. However, problems can occur where dependencies exist between messages and where it is necessary to preserve the processing order of messages. The present invention proposes an efficient method, system and apparatus for preserving the processing order of processing messages where required, whilst not unnecessarily forcing the processing order of other messages.
Claims11
A distributed processing method for processing messages in a queue, wherein the queue can accommodate a plurality of messages, each message having an identifier identifying the origin of the message and wherein the processing of the messages is performed by a plurality of processing devices, comprising:
- allocating a message from the queue for processing by an available processing device;
- determining whether other messages having the same identifier are concurrently allocated to other ones of the plurality of processing devices;
- and where it so determined, waiting for the determined other messages to be processed, prior to processing the allocated message.
A distributed processing method for processing messages in a queue, wherein the queue can accommodate a plurality of messages, each message having an identifier identifying the origin of the message and wherein the processing of the messages is performed by a plurality of processing devices, comprising:
- allocating a message from the queue for processing by an available processing device;
- maintaining record of messages allocated to the plurality of processing devices;
- determining, from the maintained record, whether other messages having the same identity are concurrently allocated to other ones of the plurality of processing devices;
- and where it so determined, waiting for the determined other prior message(s) to be processed, prior to processing the allocated message.
An article of manufacture comprising a program storage medium having computer readable program code means embodied therein for performing a method of controlling the processing of messages in a message queue of a distributed processing system, wherein the queue can accommodate a plurality of messages, each message having an identifier identifying the origin of the message and wherein the processing of the messages is performed by a plurality of processing devices, the computer readable program code means in the article of manufacture including:
- computer readable program code means for causing a computer to allocate a message from the queue for processing by an available processing device;
- computer readable program code means for causing a computer to determine whether other messages having the same identity are concurrently allocated to other ones of the plurality of processing devices;
- and
- computer readable program code means for causing a computer to, where it so determined, wait for the determined other messages to be processed, prior to processing the allocated message.
Dependencies are inferred from the claim text.