Server queuing system and method
First Claim
1. A computer-implemented method for queuing messages, comprising:
- receiving message groups in a queuing system that are sent from a sender subsystem, wherein each message group comprises at least one message;
storing the received message groups in a predetermined order using the queuing system;
receiving in the queuing system a correlation identifier for each message group, wherein the correlation identifier is used to associate message groups;
storing the received correlation identifier using the queuing system; and
sending the stored message groups in accordance with the predetermined order and the correlation identifiers.
2 Assignments
0 Petitions
Accused Products
Abstract
A queuing server is used for reliable message transport, where one subsystem desires to execute one or more ordered operations asynchronously. Messages are sent to the queue in groups, which may have one or more messages. Messages within a particular group are processed in a predetermined order. Optionally, groups of messages can marked as correlated such that all groups within a particular correlation can be processed in a predetermined order. A message can be stored in a SQL database table until processing of that message is complete. The receiving side of the message system can be scaled across multiple machines and/or across available resources of any given machine. The system can handle “disaster” scenarios on both the sending side (i.e. the sending machine crashes in the middle of sending a group), and the receiving side (i.e., a power failure causes a reboot in at least one of the receiving machines).
-
Citations
20 Claims
-
1. A computer-implemented method for queuing messages, comprising:
-
receiving message groups in a queuing system that are sent from a sender subsystem, wherein each message group comprises at least one message;
storing the received message groups in a predetermined order using the queuing system;
receiving in the queuing system a correlation identifier for each message group, wherein the correlation identifier is used to associate message groups;
storing the received correlation identifier using the queuing system; and
sending the stored message groups in accordance with the predetermined order and the correlation identifiers. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A system for queuing messages, comprising:
-
means for sending message groups in a queuing system that are sent from a sender subsystem, wherein each message group comprises at least one message;
means for storing the received message groups in a predetermined order using the queuing system;
means for receiving in the queuing system a correlation identifier for each message group, wherein the correlation identifier is used to associate message groups;
means for storing the received correlation identifier using the queuing system; and
means for sending the stored message groups in accordance with the predetermined order and the correlation identifiers. - View Dependent Claims (12, 13, 14, 15)
-
-
16. A computer-readable medium having computer-executable instructions for managing a queuing system for messages, comprising:
-
instructions for receiving message groups in a queuing system that are sent from a sender subsystem, wherein each message group comprises at least one message;
instructions for storing the received message groups in a predetermined order using the queuing system;
instructions for receiving in the queuing system a correlation identifier for each message group, wherein the correlation identifier is used to associate message groups;
instructions for storing the received correlation identifier using the queuing system; and
instructions for sending the stored message groups in accordance with the predetermined order and the correlation identifiers. - View Dependent Claims (17, 18, 19, 20)
-
Specification