Message ordering using dynamically updated selectors

• US 8,539,508 B2
• Filed: 10/29/2009
• Issued: 09/17/2013
• Est. Priority Date: 10/29/2009
• Status: Active Grant

• Current Assignee: ServiceNow Incorporated
• Original Assignee: International Business Machines Corporation
• Inventors: Bittles, William, Gormley, Simon, Titheridge, Paul, Matthewson, Chris
• Primary Examiner(s): Sough, H S
• Assistant Examiner(s): JORDAN, KIMBERLY L
• Application Number:
  US12/608,708
• Publication Number:
  US 20110107350A1
• Time in Patent Office: 1,419 Days
• Field of Search: None
• US Class Current: 719/314
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A method of queuing messages for communications between a first computer program and a second computer program, comprises: placing a plurality of messages in a queue, wherein each message has a message body; placing selector information on each message, wherein the selector information contains information as to which message is to be processed next; and using the selector information on a message to identify a next message for processing.

Claims

1. A method of queuing messages for communications between a first computer program and a second computer program, comprising the steps of:

placing a plurality of messages in a queue, wherein each message has a message body;

placing selector information on each message, a first message having first selector information, said first selector information defining a complete order of processing of messages, a subsequent message having selector information different from said first selector information, said different selector information defining a different complete order of processing messages; and

using said different selector information on said subsequent message to identify a next message for processing,

wherein a processor device performs executing one or more of;

said placing a plurality of messages, said placing selector information and said using.

2. The method of claim 1 further comprising:

placing selector information in each message prior to sending said plurality of messages from said queue.

3. The method of claim 1 wherein said placed selector information can appear on any part of each of said plurality of messages.

4. The method of claim 1, wherein said different selector information is an arbitrary function.

5. The method of claim 4 wherein said different selector information can not be changed after said subsequent message is sent from said queue.

6. The method of claim 1 wherein said plurality of messages each contain selector information that designates an order for processing said plurality of messages that is different than the order that said messages are in said queue.

7. The method of claim 1 wherein said plurality of messages each contain selector information that designates an order for processing said plurality of messages that is the same as the order that said messages are in said queue.

8. The method of claim 1 further comprising:

using a message selector for identifying a next message to be processed from selector information on an immediately prior message already processed.

9. The method of claim 8 wherein selector information in the prior message is used by said message selector to identify the next message.

10. The method according to claim 1, wherein said plurality of messages are produced by multiple producers.

11. A computer program product for use with a computer, the computer program product including a non-transitory computer readable medium having recorded thereon a computer program or program code for causing the computer to perform a method for storing and retrieving data, the method comprising:

placing a plurality of messages in a queue, wherein each message has a message body;

placing selector information on each message, a first message having first selector information, said first selector information defining a complete order of processing of messages, a subsequent message having selector information different from said first selector information, said different selector information defining a different complete order of processing messages; and

using said different selector information on said subsequent message to identify a next message for processing.

12. The computer program product of claim 11 further comprising:

placing selector information in each message prior to sending said plurality of messages from said queue.

13. The computer program product of claim 11 wherein said placed selector information can appear on any part of each of said plurality of messages.

14. The computer program product of claim 12 wherein said different selector information is an arbitrary function.

15. The computer program product of claim 14 wherein said different selector information can not be changed after said subsequent message is sent from said queue.

16. The computer program product of claim 11 wherein said plurality of messages each contain selector information that designates an order for processing said plurality of messages that is different than the order that said messages are in said first queue.

17. The computer program product of claim 11 wherein said plurality of messages each contain selector information that designates an order for processing said plurality of messages that is the same as the order that said messages are in said first queue.

18. The computer program product of claim 11 further comprising:

using a message selector for identifying a next message to be processed from selector information on an immediately prior message already processed.

19. The computer program product of claim 18 wherein selector information in the prior message is used by said message selector to identify the next message.

20. A system of queuing messages for communications between a first computer program and a second computer program, the system comprising:

a memory device;

a processor coupled to the memory device, wherein the processor is configured to perform steps of;

placing a plurality of messages in a queue, wherein each message has a message body;

placing selector information on each message, a first message having first selector information, said first selector information defining a complete order of processing of messages, a subsequent message having selector information different from said first selector information, said different selector information defining a different complete order of processing messages; and

using said different selector information on said subsequent message to identify a next message for processing.