Publish-subscribe system having a reliability mechanism

• US 7,287,066 B2
• Filed: 10/31/2003
• Issued: 10/23/2007
• Est. Priority Date: 10/31/2003
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Elms, Kim, Ruggaber, Rainer, Schmid, Alexander, Dorner, Elmar
• Primary Examiner(s): Barot; Bharat
• Application Number:
  US10/698,978
• Publication Number:
  US 20050096928A1
• Time in Patent Office: 1,453 Days
• Field of Search: 709202-203, 709/206, 709/220, 709227-228, 709/245, 709238-239, 714 1- 4, 714/55, 714/100
• US Class Current: 709/220
• CPC Class Codes: H04L 12/18 for broadcast or conference , e.g. multicast
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 12/1863 comprising mechanisms for improved reliability, e.g. status reports arrangements for detecting or preventing errors by carrying supervisory signal the return channel H04L1/16

Abstract

A publish-subscribe system includes a producer configured to publish a message and to subscribe to an acknowledgement that the message was received. The system also includes a consumer configured to subscribe to the message and to publish the acknowledgement. The system further includes a network configured to register a message subscription and an acknowledgement subscription, to process the message subscription and the acknowledgement subscription, to forward the message to the consumer based on the message subscription and to forward the acknowledgement to the producer based on the acknowledgement subscription.

Claims

1. A publish-subscribe system comprising:

a producer configured to publish a message and to subscribe to an acknowledgement that the message was received;

a consumer configured to subscribe to the message and to publish the acknowledgement; and

a network configured to register a message subscription and an acknowledgement subscription, to process the message subscription and the acknowledgement subscription, to forward the message to the consumer based on the message subscription and to forward the acknowledgement to the producer based on the acknowledgement subscription;

wherein the message subscription corresponds to a type of message content of interest to the consumer, and the acknowledgement subscription corresponds to a type of acknowledgement content of interest to the producer.

2. The system of claim 1 wherein the producer includes a reliability mechanism to subscribe to the acknowledgement associated with a published message.

3. The system of claim 1 wherein the producer includes a timer and the producer republishes the message if a period of time expires before receiving the acknowledgement.

4. The system of claim 1 wherein the consumer includes a reliability mechanism to publish the acknowledgement.

5. The system of claim 4, wherein the reliability mechanism removes duplicate messages.

6. The system of claim 1, wherein the network includes a content-based messaging (CBM) router to route the message and the acknowledgement.

7. The system of claim 1, further comprising a reliability mechanism that uses a generic addressing scheme in identifying client devices.

8. The system of claim 7, wherein the generic addressing scheme provides a unique identity to the consumer and the producer.

9. An application program interface (API) for content-based messaging comprising a computer readable storage medium for storing instructions that are executable by a processor to:

receive a message from a producer application according to a message subscription;

register an acknowledgement subscription for an acknowledgement to the message;

modify the message by adding at least one field to the message;

forward the message to an interface to publish the message to a content-based message (CBM) network; and

receive the acknowledgement from the interface according to the acknowledgement subscription;

wherein the message subscription corresponds to a type of message content of interest to the consumer, and the acknowledgement subscription corresponds to a type of acknowledgement content of interest to the producer.

10. The API of claim 9 wherein the API includes instructions to cause a processor to implement a timer and republish the message if a period of time expires before receiving the acknowledgement.

11. The API of claim 9 wherein the at least one field includes an identification field and a message type field.

12. The API of claim 9 wherein the at least one field includes a recipient field that identifies one or more receivers of the message.

13. The API of claim 10 wherein the at least one field includes a sender field that identifies a sender of the message.

14. An application program interface (API) for content-based messaging comprising a computer readable storage medium for storing instructions that are executable by a processor to:

receive a message from an interface according to a message subscription;

modify the message by removing at least one field from the message;

publish an acknowledgement to the message; and

forward the message to a consumer application according to an acknowledgement subscription;

wherein the message subscription corresponds to a type of message content of interest to the consumer, and the acknowledgement subscription corresponds to a type of acknowledgement content of interest to the producer.

15. The API of claim 14, wherein the API includes instructions to cause a processor to determine if the message has been previously received and to filter out the message if the message has previously been sent.

16. The API of claim 14, wherein the at least one field includes an identification field and a message type field.

17. The API of claim 14, wherein the at least one field includes a recipient field that identifies one or more receivers of the message.

18. The API of claim 14, wherein the at least one field includes a sender field that identifies a sender of the message.