SYSTEM AND METHOD FOR TRACKING NOTIFICATIONS IN A PUBLISH SUBSCRIBE SYSTEM

• US 20080082562A1
• Filed: 11/20/2007
• Published: 04/03/2008
• Est. Priority Date: 11/04/2004
• Status: Active Grant

• Current Assignee: Sean Rooney
• Original Assignee: Sean Rooney
• Inventors: Rooney, Sean
• Granted Patent: US 8,165,992 B2
• Time in Patent Office: Days
• US Class Current: 707/101
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

A system and method are provided for tracking notification messages from a message publisher to a message subscriber. The system includes a plurality of entities that are operatively coupled to one another via an electronic network, and each entity includes at least one processor configured as a message publisher, a channel and/or a message subscriber. According to the invention, at least one entity is configured as a channel, which is assigned to the function of acting as a meta-channel and comprises (i) means for receiving one or more channel descriptions; and (ii) means for publishing a digest of one or more channel descriptions and/or message transformations to facilitate tracking of message transformations from raw forms to processed forms. The system may have more than one meta-channel, and the meta-channels may subscribe to or publish to each other.

Claims

1. A method for tracking notification messages from a message publisher to a message subscriber, in a publish/subscribe system having one or more entities each configured as one or more of a message publisher, a channel and a message subscriber, the method comprising:

subscribing to a meta-channel, said meta-channel receiving descriptions of one or more associated channels;

receiving a digest of said channel descriptions from said meta-channel, said digest enabling a subscriber or a publisher, respectively, to discriminate between channels and to switch channels based on said discrimination, and

using said channel descriptions to discriminate between channels in order to determine where to subscribe or publish, respectively,

wherein said switching of channels based on said discrimination serves to automatically reconfigure said publish/subscribe system in response to overloading or failure of one or more channels in said system.

2. The method of claim 1, further comprising

receiving a digest of one or more transformation description messages from said meta-channel, said digest enabling a subscriber to track evolution of message transformations and to switch publishers based on said tracking;

and

using said transformation description messages to track evolution of message transformations in order to determine where to subscribe.

3. The method of claim 2, further comprising:

subscribing to a first channel in response to the tracking of message transformations; and

dropping a subscription to a second channel in response to determining that the first channel publishes one or more notifications in a more processed form than a notification from the second channel.

4. The method of claim 2, wherein the message transformations in processed form comprise aggregations of messages in raw form.

5. The method of claim 2, wherein the message transformations in processed form comprise transformations of messages in raw form.

6. The method of claim 1, further comprising publishing aggregated notifications.

7. The method of claim 1, further comprising publishing transformed notifications.

8. The method of claim 2, wherein the message transformations are formatted in accordance with XML specifications.

9. The method of claim 1, wherein the digest of said channel descriptions describes one or more of a channel and the meta-channel.

10. The method of claim 1, wherein each of the one or more channel descriptions comprises one or more of:

the publish/subscribe system'"'"'s type;

information needed to connect to a channel associated with the channel description;

one or more message types that is accepted by the channel associated with the channel description; and

one or more message types that is currently being published or subscribed to by the channel associated with the channel description.

11. The method of claim 1, wherein each of the one or more channel descriptions comprises load information pertaining to the channel associated with the channel description.

12. The method of claim 11, further comprising:

in response to the load information, discriminating between first and second channels offering similar functionality.

13. The method of claim 12, further comprising:

subscribing to the first channel in response to determining that the second channel is overloaded.

14. The method of claim 12, further comprising:

publishing to the first channel in response to determining that the second channel is overloaded.

15. The method of claim 1, wherein each of the one or more channel descriptions comprises information pertaining to a refresh period between a publication of a first channel description and a publication of a second channel description.

16. The method of claim 15, further comprising:

in response to the information pertaining to the refresh period, and in response to nonreception of a second channel description after a time period proportional to the refresh period, determining that a channel has stopped publishing notifications.

17. The method of claim 16, further comprising adjusting a refresh period for a channel in response to information pertaining to a refresh period for the meta-channel.

18. The method of claim 2, wherein the transformation description message pertaining to an entity comprises one or more of:

information identifying a set of channels and message types for messages that the entity is reading;

information identifying a set of channels and message types for messages that the entity is writing; and

a refresh period.

19-26. -26. (canceled)