Just-in-time publishing via a publish/subscribe messaging system having message publishing controls

• US 20060117035A1
• Filed: 12/01/2004
• Published: 06/01/2006
• Est. Priority Date: 12/01/2004
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Stewart, Eben P., Van Der Meulen, Michael, Stokes, Matthew
• Granted Patent: US 7,383,266 B2
• 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
• CPC Class Codes: Y10S 707/99933 Query processing, i.e. searching
• CPC Class Codes: Y10S 707/99936 Pattern matching access
• CPC Class Codes: Y10S 707/99939 Privileged access

Abstract

A system, method and program product having at least one subscriber subscribing to topics from one or more data sources. The number of subscriptions for each data source are registered in a table in real time. Upon detecting subscription activity, a matching routine compares the number of subscriptions registered for the available data source with a predetermined value, and if the number of subscribers exceeds the predetermined value a data source process corresponding to the data source will be started, and messages from the data source will be sent to the data source subscriber/s, otherwise, the data source provider will be stopped and not longer send messages.

Claims

1. In a publish/subscribe system having one or more subscribers subscribing to data from one or more data sources, a just-in-time pub/sub messaging system comprising:

a table for recording the data sources existing in the system and the number of subscriptions for the data sources subscribed to by the subscribers; and

a subscription process having a matching routine preventing a subscribed to data source from delivering messages to subscribers if the number of subscriptions in said table for that subscribed to data source does not exceed a predetermined number.

2. The sub/pub messaging system according to claim 1 further comprising a subscription monitor monitoring in real time, subscriptions from subscribers and recording in user subscription portion of said table the number of subscriptions for each data source in the system such that there is real-time collection of subscriptions for data from said data sources.

3. The sub/pub messaging system according to claim 2 further comprising:

a data source registry recording in a data source portion of said table, the existence of each data source having data for transmission to the subscribers, and

a data source process associated with each data source, each data source process controlled by said matching process such that when said matching process determines that a data source has not been subscribed to by said subscribers more than a predetermined number of times, the data source process associated with that data source is turned off such that messages may not be transmitted from that data source to said subscribers.

4. The sub/pub messaging system according to claim 1 wherein said predetermined number is zero.

5. The sub/pub messaging system according to claim 1 wherein said predetermined number is dynamically changeable.

6. The sub/pub message system according to claim 5 wherein said predetermined number is changed in accordance with one or more of the time of day, or the message load on the system, or the popularity of data source.

7. The sub/pub message system according to claim 1 wherein said data sources are dynamically changeable and are unknown to the subscribers and to the system at runtime.

8. In a publish/subscribe system having one or more subscribers subscribing to data from one or more data sources, a method of providing just-in-time pub/sub messages comprising:

recording in a table, the data sources existing in the system and the number of subscriptions for the data sources subscribed to by the subscribers; and

preventing a subscribed to data source from delivering messages to subscribers if the number of subscriptions in said table for that data source does not exceed a predetermined number.

9. The sub/pub messaging method according to claim 8 further comprising monitoring in real time, subscriptions from subscribers and recording in a user subscriptions portion of said table the number of subscriptions for each data source in the system such that there is real-time collection of subscriptions for data from said data sources.

10. The sub/pub messaging method according to claim 9 further comprising:

recording with a data source registry in a data source portion of said table, the existence of each data source having data for transmission to said subscribers, and

turning off with a matching routine, any data source process associated with a data source if that data source has not been subscribed to by said subscribers more that a predetermined number of times, such that messages from a data source associated with a turned off data source process may not transmit messages to the subscribers.

11. The sub/pub messaging method according to claim 8 further comprising setting said predetermined number to zero.

12. The sub/pub messaging method according to claim 8 further comprising dynamically changing said predetermined number.

13. The sub/pub message method according to claim 12 further comprising changing said predetermined number in accordance with one or more of the time of day, or the message load on the system, or the popularity of data source.

14. The sub/pub message method according to claim 8 wherein said data sources are dynamically changeable and are unknown to the subscribers and to the system at runtime.

15. A computer program product for use in a publish/subscribe system having one or more subscribers subscribing to data from one or more data sources, said computer program product comprising one or more computer readable media having recorded thereon computer readable program instructions for executing a method of providing just-in-time pub/sub messages, said method comprising:

recording in a table, the data sources existing in the system and the number of subscriptions for the data sources subscribed to by the subscribers; and

preventing a subscribed to data source from delivering messages to subscribers if the number of subscriptions in said table for that data source does not exceed a predetermined number.

16. The computer program product according to claim 15 wherein said sub/pub messaging method further comprises monitoring in real time, subscriptions from subscribers and recording in a user subscriptions portion of said table the number of subscriptions for each data source in the system such that there is real-time collection of subscriptions for data from said data sources.

17. The computer program product according to claim 16 wherein said sub/pub messaging method further comprises:

recording with a data source registry in a data source portion of said table, the existence of each data source having data for transmission to said subscribers, and

turning off with a matching routine, any data source process associated with a data source if that data source has not been subscribed to by said subscribers more that a predetermined number of times, such that messages from a data source associated with a turned off data source process may not transmit messages to the subscribers.

18. The computer program product according to claim 15 wherein said sub/pub messaging method further comprises setting said predetermined number to zero.

19. The computer program product according to claim 15 wherein said sub/pub messaging method further comprises dynamically changing said predetermined number.

20. The computer program product according to claim 19 wherein said sub/pub messaging method further comprises changing said predetermined number in accordance with one or more of the time of day, or the message load on the system, or the popularity of data source.

21. The computer program product according to claim 15 wherein said computer readable program instructions comprises program instructions which may read data from data sources which are dynamically changeable and are unknown to the subscribers and to the system at runtime.