Control of publish/subscribe messaging

• US 20060047666A1
• Filed: 08/23/2005
• Published: 03/02/2006
• Est. Priority Date: 08/28/2004
• Status: Abandoned Application

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Carter, Marc Stanley, Stanford-Clark, Andrew James, Bedi, Bharat Veer
• Application Number:
  US11/209,445
• Publication Number:
  US 20060047666A1
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/958 Organisation or management of web site content, e.g. publishing, maintaining pages or automatic linking

Abstract

Subscribers connected to a publish/subscribe message broker receive messages on topic names to which they have subscribed. The messages are published with respective topic names within a sequence of topic names. The subscribers initially subscribe to at least one topic in the sequence, and then await receipt of a published message on the subscribed topic. On receipt of a published message, the subscriber unsubscribes from the subscribed topic and subscribes to a previously-unsubscribed next topic in the sequence.

Claims

1. A method for controlling receipt by a subscriber of messages having a respective topic name in a publish/subscribe messaging network, the method comprising:

subscribing to at least one topic name within a sequence of topic names;

receiving a published message having a first topic name to which the subscriber is subscribed; and

unsubscribing from the first topic name in response to receiving the published message.

2. The method of claim 1, wherein subscribing to at least one topic name within a sequence of topic names comprises subscribing to a group of topic names within the sequence of topic names.

3. The method of claim 2, further comprising:

processing a received message having a first topic name; and

receiving a message having a second topic name in the sequence of topic names concurrently with processing said received message.

4. The method of claim 1, further comprising:

subscribing to a previously-unsubscribed topic name comprising a next available topic name in the sequence of topic names.

5. The method of claim 1, further comprising communicating with a publish/subscribe message broker to request updates to subscription information stored by the broker for the respective subscriber.

6. A method for controlling delivery of published messages to subscribers by a publish/subscribe message broker, wherein the message broker maintains subscription information identifying subscribers to respective message topics, the method comprising:

receiving a published message from a publisher;

transmitting the published message to at least one subscriber, wherein the transmitted message has a first topic name within a sequence of topic names and is transmitted to subscribers that are subscribed to receive messages having the first topic name;

receiving an unsubscribe request from the first subscriber which unsubscribe request specifies the first topic name subsequent to transmitting a received message having the first topic name to a first subscriber; and

updating the subscription information maintained at the message broker such that the first subscriber is no longer subscribed to receive messages having the first topic name in response to receiving the unsubscribe request.

7. The method of claim 6, further comprising:

updating the subscription information maintained at the message broker to subscribe the first subscriber to a previously-unsubscribed topic name comprising a next available topic name in the sequence of topic names.

8. The method of claim 6, further comprising:

executing a process at the message broker to automatically generate a topic hierarchy comprising the sequence of topic names.

9. The method of claim 6, wherein the messages are published in a multicast manner.

10. The method of claim 6, further comprising:

publishing a message on a first predefined meta topic containing the name of the unsubscribed topic.

11. A method for controlling republication of messages by a publisher in a publish/subscribe messaging network, the method comprising:

assigning sequential topic names to a sequence of messages and publishing the messages with their respective assigned topic name;

checking whether any subscribers are active for assigned topic names; and

republishing messages having topic names for which said checking determines that at least one subscriber is active, without republishing messages having topic names for which no subscribers are active.

12. The method of claim 11, wherein checking whether any subscribers are active for assigned topic names comprises communicating to a message broker a desire for informati0on regarding subscription updates for one or more specified topic names.

13. A computer program product for controlling delivery of published messages to subscribers in a publish/subscribe messaging system, the computer program product comprising:

a computer usable medium having computer usable program code embodied therein, the computer usable program code comprising,

computer usable program code configured to subscribe to at least one topic name within a sequence of topic names;

computer usable program code configured to receive a published message having a first topic name to which the subscriber is subscribed; and

computer usable program code configured to unsubscribe from the first topic name in response to receiving the published message.

14. A computer program product for controlling delivery of published messages to subscribers in a publish/subscribe messaging system, the computer program product comprising:

a computer usable medium having computer usable program code embodied therein, the computer usable program code comprising,

computer usable program code configured to receive a published message from a publisher;

computer usable program code configured to transmit the published message to at least one subscriber, wherein the transmitted message has a first topic name within a sequence of topic names and is transmitted to subscribers that are subscribed to receive messages having the first topic name;

computer usable program code configured to receive an unsubscribe request from the first subscriber which unsubscribe request specifies the first topic name subsequent to transmitting a received message having the first topic name to a first subscriber; and

computer usable program code configured to update the subscription information maintained at the message broker such that the first subscriber is no longer subscribed to receive messages having the first topic name in response to receiving the unsubscribe request.

15. A computer program product for controlling republication of messages by a publisher in a publish/subscribe messaging system, the computer program product comprising:

a computer usable medium having computer usable program code embodied therein, the computer usable program code comprising,

computer usable program code configured to assign sequential topic names to a sequence of messages and publishing the messages with their respective assigned topic name;

computer usable program code configured to check whether any subscribers are active for assigned topic names; and

computer usable program code configured to republish messages having topic names for which said checking determines that at least one subscriber is active, without republishing messages having topic names for which no subscribers are active.

16. A data processing system for controlling delivery of published messages to subscribers according to a publish/subscribe messaging model, the system comprising:

a data processing unit;

a data storage unit; and

a subscriber program configured to subscribe to at least one topic name within a sequence of topic names;

receive a published message having a first topic name to which the subscriber is subscribed; and

unsubscribe from the first topic name in response to receiving the published message.

17. A data processing system for controlling delivery of published messages to subscribers according to a publish/subscribe messaging model, the system comprising:

a data processing unit;

a data storage unit; and

a message broker program configured to receive a published message from a publisher;

transmit the published message to at least one subscriber, wherein the transmitted message has a first topic name within a sequence of topic names and is transmitted to subscribers that are subscribed to receive messages having the first topic name;

receive an unsubscribe request from the first subscriber which unsubscribe request specifies the first topic name subsequent to transmitting a received message having the first topic name to a first subscriber; and

update the subscription information maintained at the message broker such that the first subscriber is no longer subscribed to receive messages having the first topic name in response to receiving the unsubscribe request.

18. A data processing system for controlling publication of messages for publish/subscribe messaging, the system comprising:

a data processing unit;

a data storage unit; and

a publisher program configured to;

assign sequential topic names to a sequence of messages and publishing the messages with their respective assigned topic name;

check whether any subscribers are active for assigned topic names; and

republish messages having topic names for which said checking determines that at least one subscriber is active, without republishing messages having topic names for which no subscribers are active.