Optimizing storage in a publish / subscribe environment

• US 9,501,512 B2
• Filed: 03/25/2016
• Issued: 11/22/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:
  US15/080,631
• Publication Number:
  US 20160196293A1
• Time in Patent Office: 242 Days
• 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 for managing at least a master copy of a non-transitory machine readable data file in a database according to a publication subscription system model, the method comprising:

saving the machine readable data file corresponding to a first message in the database as the master copy of the machine readable data file;

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

generating consumption metadata includes data indicating whether each subscriber of the list of subscribers is has, or is likely to want to, consume the first message;

responsive to adding a new subscriber to the list of subscribers, revising the consumption metadata to include data indicating whether the new subscriber has, or is likely to want to, consume the first message;

responsive to a determination that an inactive subscriber has become inactive, revising the consumption metadata to remove data relating to the inactive subscriber;

on condition that the consumption data indicates that at least one subscriber has not, and is not likely to, consume the first message, duplicating the first message; and

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

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