Subscription-based data delivery system
AssigneeHadean Supercomputing Ltd
InventorsRashid Mohamed Mansoor, James Kay, Christopher Sinclair, Douglas Wilson
Life of this patent
Estimating the term…
Abstract
There is provided a computer-implemented method comprising, at an intermediary process acting as an intermediary between a publisher system and a plurality of subscriber processes, the intermediary process having a publisher data store storing one or more subscriptions for which the intermediary process is a publisher and a subscriber data store storing one or more subscriptions for which the intermediary process is a subscriber.
Claims20
A computer-implemented method comprising, at an intermediary process acting as an intermediary between a publisher system and a plurality of subscriber processes, the intermediary process having a publisher data store storing one or more subscriptions for which the intermediary process is a publisher and a subscriber data store storing one or more subscriptions for which the intermediary process is a subscriber:
- receiving, from a first one of the plurality of subscriber processes, a first subscription request comprising a first subscription for the first subscriber process;
- storing, in the publisher data store, a record associating the first subscriber process with the first subscription;
- determining whether the one or more subscriptions in the subscriber data store collectively cover the first subscription;
- and
- responsive to determining that the one or more subscriptions in the subscriber data store do not collectively cover at least a portion of the first subscription, sending, to the publisher system, a second subscription request comprising a second subscription for the intermediary process, the second subscription comprising at least the at least a portion of the first subscription, and storing, in the subscriber data store, a record of the second subscription.
A computer-implemented method comprising, at an intermediary process acting as an intermediary between a publisher system and a plurality of subscriber processes, the intermediary process having a publisher data store storing one or more subscriptions for which the intermediary process is a publisher, a subscriber data store storing one or more subscriptions for which the intermediary process is a subscriber, and a state data store storing state data:
- receiving first event data from the publisher system;
- updating the state data in the state data store based on the first event data;
- generating, from the state data in the state data store, second event data according to a first subscription associated with a first one of the subscriber processes in the publisher data store;
- and
- sending the second event data to the first subscriber process.
A non-transitory computer-readable medium comprising instructions which, when executed by one or more computers, cause the one or more computers to perform a method comprising, at an intermediary process acting as an intermediary between a publisher system and a plurality of subscriber processes, the intermediary process having a publisher data store storing one or more subscriptions for which the intermediary process is a publisher, a subscriber data store storing one or more subscriptions for which the intermediary process is a subscriber, and a state data store storing state data:
- receiving first event data from the publisher system;
- updating the state data in the state data store based on the first event data;
- generating, from the state data in the state data store, second event data according to a first subscription associated with a first one of the subscriber processes in the publisher data store;
- and
- sending the second event data to the first subscriber process.
Dependencies are inferred from the claim text.