Random access for processing messages in a message queue
First Claim
1. A method of random access for processing messages in a message queue, the method comprising:
- creating a map relating message identification and message position, including adding an entry in the map whenever a message enters the queue;
instantiating a number of consumer applications for the messages, including assigning an ordinal value to each consumer application; and
consuming, with the consumer applications, the messages in dependence upon the map, including identifying the messages to be processed by each consumer application in dependence upon the ordinal value, the number of the consumer applications, and the message position, including assigning for consumption by a consumer application a message having a message position identified by adding the ordinal value of the consumer application to the product of the number of the consumer applications multiplied by the number of messages consumed by the consumer application.
2 Assignments
0 Petitions
Accused Products
Abstract
Methods, systems, and products for random access for processing messages in a message queue that include creating a map relating message identification and message position, including adding an entry in the map whenever a message enters the queue; instantiating a plurality of consumers for the messages; and consuming, with the consumers, the messages in dependence upon the map. In typical embodiments, the plurality of consumers includes a particular number of consumers and such embodiments typically include assigning an ordinal value to each consumer and consuming the messages further comprises identifying the messages to be processed by each consumer in dependence upon the ordinal values, the number of consumers, and the message positions.
30 Citations
15 Claims
-
1. A method of random access for processing messages in a message queue, the method comprising:
-
creating a map relating message identification and message position, including adding an entry in the map whenever a message enters the queue; instantiating a number of consumer applications for the messages, including assigning an ordinal value to each consumer application; and consuming, with the consumer applications, the messages in dependence upon the map, including identifying the messages to be processed by each consumer application in dependence upon the ordinal value, the number of the consumer applications, and the message position, including assigning for consumption by a consumer application a message having a message position identified by adding the ordinal value of the consumer application to the product of the number of the consumer applications multiplied by the number of messages consumed by the consumer application. - View Dependent Claims (2, 3, 4, 5)
-
-
6. An apparatus providing random access for processing messages in a message queue, the apparatus comprising a computer processor, a computer memory operatively coupled to the computer processor, the computer memory having disposed within it computer program instructions capable when executed of causing the apparatus to carry out the steps of:
-
creating a map relating message identification and message position, including adding an entry in the map whenever a message enters the queue; instantiating a number of consumer applications for the messages, including assigning an ordinal value to each consumer application; and consuming, with the consumer applications, the messages in dependence upon the map, including identifying the messages to be processed by each consumer application in dependence upon the ordinal value, the number of the consumer applications, and the message position, including assigning for consumption by a consumer application a message having a message position identified by adding the ordinal value of the consumer application to the product of the number of the consumer applications multiplied by the number of messages consumed by the consumer application. - View Dependent Claims (7, 8, 9, 10)
-
-
11. A computer program product providing random access for processing messages in a message queue, the computer program product embodied on a computer-readable recording medium, the computer program product comprising computer program instructions, which when installed and executed on automated apparatus, perform the steps of:
-
creating a map relating message identification and message position, including adding an entry in the map whenever a message enters the queue; instantiating a number of consumer applications for the messages, including assigning an ordinal value to each consumer application; and consuming, with the consumer applications, the messages in dependence upon the map, including identifying the messages to be processed by each consumer application in dependence upon the ordinal value, the number of the consumer applications, and the message position, including assigning for consumption by a consumer application a message having a message position identified by adding the ordinal value of the consumer application to the product of the number of the consumer applications multiplied by the number of messages consumed by the consumer application. - View Dependent Claims (12, 13, 14, 15)
-
Specification