Consuming Ordered Streams of Messages in a Message Oriented Middleware

A system for consuming ordered streams of messages in a message oriented middleware having a single queue, comprising:

• an application thread availability component providing a first consuming application thread to process a first message;
• a message availability component determining the first message is available on the queue;
• a locking component for locking the first message available on the queue to the first consuming application thread and locking all subsequent messages on the queue with a same stream identifier as the first message to the first consuming application thread;
• a lock check component for identifying further messages with different stream identifiers currently locked to the first consuming application thread;
• a lock release component for making available the further messages to other consuming application threads;
• and
• a message delivery component for delivering the first message to the first consuming application thread.

A computer program product for consuming ordered streams of messages in a message oriented middleware having a single queue, the computer program product comprising:

• a computer readable storage medium readable by a processing circuit and storing instructions for execution by the processing circuit to:
• provide a first consuming application thread to process a first message;
• locking a first message available on a queue to the first consuming application thread and locking all subsequent messages on the queue with same stream identifiers as the message to the first consuming application thread;
• identifying further messages with different stream identifiers currently locked to the first application thread, and making available the further messages to other consuming application threads;
• and
• delivering the first message to the first consuming application thread.