SYSTEM FOR PRESERVING MESSAGE ORDER
First Claim
1. A method of preserving the order of messages in an asynchronous message system, comprising:
- generating a message;
tagging the generated message with a sequence identifier and a sequence number, wherein the sequence number is unique within a sequence of messages identified by a common sequence identifier;
processing the tagged message by;
checking a log to determine whether the sequence identifier of the tagged message is in the log;
sending the tagged message to a selected consumer if the sequence identifier of the tagged message is not in the log;
sending the tagged message to a particular consumer if the sequence identifier of the tagged message is in the log, where the particular consumer is identified based upon a consumer identifier read from a log entry containing the sequence identifier; and
writing to the log, an entry having the sequence identifier and the sequence number of the tagged message and a consumer identifier of the selected consumer to whom the message is sent if the sequence identifier of the tagged message is not in the log.
0 Assignments
0 Petitions
Accused Products
Abstract
The order of messages in an asynchronous message system is preserved, by generating a message and tagging the generated message with a sequence identifier and a sequence number. The order of messages is further preserved by processing the tagged message by checking a log to determine whether the sequence identifier is in the log, sending the tagged message to a selected consumer if the sequence identifier is not in the log and sending the tagged message to a particular consumer if the sequence identifier is in the log. Still further, the order of messages is preserved by writing an entry to the log having the sequence identifier and the sequence number of the tagged message and a consumer identifier of the selected consumer if the sequence identifier of the tagged message is not in the log.
-
Citations
20 Claims
-
1. A method of preserving the order of messages in an asynchronous message system, comprising:
-
generating a message; tagging the generated message with a sequence identifier and a sequence number, wherein the sequence number is unique within a sequence of messages identified by a common sequence identifier; processing the tagged message by; checking a log to determine whether the sequence identifier of the tagged message is in the log; sending the tagged message to a selected consumer if the sequence identifier of the tagged message is not in the log; sending the tagged message to a particular consumer if the sequence identifier of the tagged message is in the log, where the particular consumer is identified based upon a consumer identifier read from a log entry containing the sequence identifier; and writing to the log, an entry having the sequence identifier and the sequence number of the tagged message and a consumer identifier of the selected consumer to whom the message is sent if the sequence identifier of the tagged message is not in the log. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A computer-readable storage medium with an executable program stored thereon for preserving the order of messages in an asynchronous message system, wherein the program instructs a microprocessor to perform the following:
-
generating a message; tagging the generated message with a sequence identifier and a sequence number, wherein the sequence number is unique within a sequence of messages identified by a common sequence identifier; processing the tagged message by; checking a log to determine whether the sequence identifier of the tagged message is in the log; sending the tagged message to a selected consumer if the sequence identifier of the tagged message is not in the log; sending the tagged message to a particular consumer if the sequence identifier of the tagged message is in the log, where the particular consumer is identified based upon a consumer identifier read from a log entry containing the sequence identifier; and writing to the log, an entry having the sequence identifier and the sequence number of the tagged message and a consumer identifier of the selected consumer to whom the message is sent if the sequence identifier of the tagged message is not in the log. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
Specification