Optimizing storage in a publish / subscribe environment

• US 9,465,880 B2
• Filed: 05/14/2013
• Issued: 10/11/2016
• Est. Priority Date: 05/14/2013
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Gray-Donald, Trent A., Lalgowdar, Rajesh, Thyagaraj, Lohitashwa
• Primary Examiner(s): Chen, Susan
• Application Number:
  US13/893,813
• Publication Number:
  US 20140344314A1
• Time in Patent Office: 1,246 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 16/23 Updating
• CPC Class Codes: G06F 16/958 Organisation or management of web site content, e.g. publishing, maintaining pages or automatic linking
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 51/046 Interoperability with other network applications or services
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

Creating message files in a publication subscription computer system by: (i) receiving data corresponding to a first message; (ii) receiving a list of subscribers that subscribe to a topic of the first message; and (iii) creating a digital data file that includes a payload data and a consumption metadata. The payload data includes content data corresponding to the first message. The consumption metadata includes data relating to whether one or more subscribers of the list of subscribers will potentially consume the first message at a later period in time from the time of receiving the content data corresponding to the first message.

Claims

1. A method of creating machine readable message files in a publication subscription system implemented with a plurality of computers, the method comprising:

receiving data corresponding to a first message;

receiving a list identifying a plurality of subscribers that subscribe to a topic of the first message;

creating a machine readable data file that includes a payload data and a consumption metadata, with;

(i) the payload data including content data corresponding to the first message, and (ii) the consumption metadata including data indicating whether each subscriber of the plurality of subscribers has respectively consumed the first message;

storing a master copy of the machine readable data file in a persistent storage database;

each time a subscriber of the plurality of subscribers consumes the first message, updating the consumption metadata to indicate consumption of the first message by the subscriber;

determining that all subscribers of the plurality of subscribers have consumed the first message based on the consumption metadata; and

on condition of a determination that all subscribers have consumed the first message, deleting the master copy of the machine readable data file from the persistent storage database;

wherein

the consumption metadata includes a binary bit to respectively indicate consumption status for each subscriber of the plurality of subscribers.

2. The method of claim 1 further comprising:

subsequent to the creating step, updating the consumption metadata to add or subtract a binary bit to reflect a change in the number of subscribers in the plurality of subscribers.

3. A computer program product used to create machine readable message files in a publication subscription system implemented with a plurality of computers, the product comprising software stored on a software storage device, the software comprising:

first program instructions programmed to receive data corresponding to a first message;

second program instructions programmed to receive a list identifying a plurality of subscribers that subscribe to a topic of the first message;

third program instructions programmed to create a machine readable data file that includes payload data and consumption metadata, with;

(i) the payload data including content data corresponding to the first message, and (ii) the consumption metadata including data indicating whether each subscriber of the plurality of subscribers has respectively consumed the first message;

fourth program instructions programmed to store a master copy of the machine readable data file in a persistent storage database;

fifth program instructions programmed to each time a subscriber of the plurality of subscribers consumes the first message, update the consumption metadata to indicate consumption of the first message by the subscriber;

sixth program instructions programmed to determine that all subscribers of the plurality of subscribers have consumed the first message based on the consumption metadata; and

seventh program instructions programmed to on condition of a determination that all subscribers have consumed the first message, delete the master copy of the machine readable data file from the persistent storage database;

wherein;

the third program instructions are further programmed to include a binary bit, in the consumption metadata, to respectively indicate consumption status for each subscriber of the plurality of subscribers.

4. The computer program product of claim 3 wherein the software further comprises:

eighth program instructions programmed to update the consumption metadata to add or subtract a binary bit to reflect a change in the number of subscribers in the plurality of subscribers.

5. A computer system used to make machine readable message files in a publication subscription system, the computer system comprising:

a processor(s) set; and

a software storage device;

wherein;

the processor set is structured, located, connected and programmed to run software stored on the software storage device;

the software comprises;

first program instructions programmed to receive data corresponding to a first message,

second program instructions programmed to receive a list identifying a plurality of subscribers that subscribe to a topic of the first message,

third program instructions programmed to create a machine readable data file that includes payload data and consumption metadata, with;

(i) the payload data including content data corresponding to the first message, and (ii) the consumption metadata including data indicating whether each subscriber of the plurality of subscribers has respectively consumed the first message,

fourth program instructions programmed to store a master copy of the machine readable data file in a persistent storage database,

fifth program instructions programmed to each time a subscriber of the plurality of subscribers consumes the first message, update the consumption metadata to indicate consumption of the first message by the subscriber,

sixth program instructions programmed to determine that all subscribers of the plurality of subscribers have consumed the first message based on the consumption metadata, and

seventh program instructions programmed to on condition of a determination that all subscribers have consumed the first message, delete the master copy of the machine readable data file from the persistent storage database,

wherein;

the third program instructions are further programmed to include a binary bit, in the consumption metadata, to respectively indicate consumption status for each subscriber of the plurality of subscribers.

6. The computer system of claim 5 wherein the software further comprises:

eighth program instructions programmed to update the consumption metadata to add or subtract a binary bit to reflect a change in the number of subscribers in the plurality of subscribers.