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

• US 8,090,687 B2
• Filed: 04/08/2008
• Issued: 01/03/2012
• Est. Priority Date: 12/01/2004
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Stewart, Eben P., Stokes, Matthew, Van Der Meulen, Michael
• Primary Examiner(s): Wong, Don
• Assistant Examiner(s): HO, BINH VAN
• Application Number:
  US12/099,627
• Publication Number:
  US 20080196042A1
• Time in Patent Office: 1,365 Days
• Field of Search: 707/629
• US Class Current: 707/629
• 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 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 publish/subscribe messaging system comprising:

a computer memory;

a first table for recording in real time, the data sources existing in the system;

a second table for recording user subscriptions for the data sources subscribed to by the user subscribers;

a subscription process preventing a subscribed to data source recorded in said first table as being available from delivering messages to user subscribers if the number of user subscriptions in said second table for that data source does not exceed a predetermined number;

a monitoring process for monitoring in real time, user subscriptions from user subscribers and recording in said second table the user subscriptions for each data source in the system such that there is real-time collection of user subscriptions for data from said available data sources;

a data source registry in said first table for recording the availability of each data source having data for transmission to said user subscribers, and

a matching routine turning off any data source process associated with a data source if that data source has not been subscribed to by said user subscribers more than 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 user subscribers.

2. The publish/subscripe messaging system according to claim 1 wherein said predetermined number is zero.

3. The publish/subscribe messaging system according to claim 1 wherein said predetermined number is dynamically changeable.

4. The publish/subscribe message system according to claim 3 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.

5. The publish/subscribe 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.

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

recording in a first table in real time, the data sources available in the system and in a second table, user subscriptions for the data sources subscribed to by user subscribers;

preventing a subscribed to data source recorded in said first table as being available from delivering messages to user subscribers if the number of user subscriptions in said second table for that data source does not exceed a predetermined number;

monitoring in real time, user subscriptions from user subscribers and recording in said second table the user subscriptions for each data source in the system such that there is real-time collection of user subscriptions for data from said available data sources;

recording with a data source registry in said first table, the availability of each data source having data for transmission to said user 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 user subscribers more than 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 user subscribers.

7. The product according to claim 6 wherein said publish/subscribe messaging method further comprises setting said predetermined number to zero.

8. The product according to claim 6 wherein said publish/subscribe messaging method further comprises dynamically changing said predetermined number.

9. The product according to claim 8 wherein said publish/subscribe 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.

10. The product according to claim 6 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.