Duplicate message elimination system for a message broker
First Claim
1. A method for preventing delivery of duplicate messages in a message system, wherein each message comprises a unique message identifier;
- the method comprising the steps of;
polling a message store for messages;
retrieving from the message store at least one message;
processing the at least one message;
retrieving a message identifier from a monitor queue in a transactional server, the message identifier corresponding to the last successfully delivered message; and
comparing the message identifier retrieved from the monitor queue to the message identifier of the message retrieved from the message store.
1 Assignment
0 Petitions
Accused Products
Abstract
A method for preventing the delivery of duplicate messages in a message system, wherein each message comprises a unique message identifier that identifies itself from adjacent messages, comprises the steps of polling a message store for messages directed to a specified receiver; receiving from the message store at least one message directed to the specified receiver; processing the at least one message; receiving, from a monitor queue, a message identifier for the last message successfully delivered to the specified receiver; and comparing the message identifier received from the monitor queue to the message identifier of the message received from the message store.
-
Citations
21 Claims
-
1. A method for preventing delivery of duplicate messages in a message system, wherein each message comprises a unique message identifier;
- the method comprising the steps of;
polling a message store for messages;
retrieving from the message store at least one message;
processing the at least one message;
retrieving a message identifier from a monitor queue in a transactional server, the message identifier corresponding to the last successfully delivered message; and
comparing the message identifier retrieved from the monitor queue to the message identifier of the message retrieved from the message store. - View Dependent Claims (2, 3, 4, 5, 6)
- the method comprising the steps of;
-
7. A message system wherein each message comprises a unique identifier that identifies itself from adjacent messages, the message system comprising:
a message transfer agent for processing messages, comprising logic for;
retrieving a message from a message store; and
comparing the unique identifier for the retrieved message to the unique identifier for the message which was last successfully delivered; and
if the compared identifiers do not match, sending the retrieved message to a transactional server for storage in a destination queue; and
sending the unique identifier for the retrieved message to a monitor queue for storage in a monitor queue in a transactional server.- View Dependent Claims (8, 9, 10, 11)
-
12. A transactional server comprising:
a message broker for receiving messages sent from a message store and for serving the messages on recipients, wherein the message broker comprises a delivery queue and a monitor queue for storing an identifier corresponding to the last message successfully delivered. - View Dependent Claims (13, 14, 15, 16, 17, 18)
-
19. A program product comprising instructions for causing a processor to:
-
poll a message store for messages directed to a specified receiver;
receive from the message store at least one message directed to the specified receiver;
process the at least one message;
receive, from a monitor queue, a message identifier for the last message successfully delivered to the specified receiver; and
compare the message identifier received from the monitor queue to the message identifier of the message received from the message store. - View Dependent Claims (20, 21)
-
Specification