Publish-subscribe messaging in a content network
First Claim
1. A method comprising the steps of:
- registering a plurality of client devices to receive, from a publisher component, via a broker component, at least one of messages and content pertaining to a first topic;
causing each of said client devices to generate one of N random numbers, a different one of N random numbers being generated by each of said client devices;
instructing each of said client devices to listen only for said at least one of messages and content pertaining to said first topic and corresponding to said one of N random numbers generated by each corresponding one of said client devices;
publishing said at least one of messages and content pertaining to said first topic from said publisher component, via said broker component, to those of said client devices associated with each one of said N random numbers, number by number, until said at least one of messages and content pertaining to said first topic has been published to all of said plurality of client devices;
listening, at an interceptor component, for said at least one of messages and content pertaining to a first topic published from the publisher component to the plurality of client devices, via the broker component, said least one of messages and content including a uniform resource locator of said publisher component;
intercepting said at least one of messages and content pertaining to said first topic with said interceptor component;
re-publishing, with said interceptor component, to a second topic different than said first topic, said random numbers corresponding to destination client devices for each of said intercepted at least one of messages and content pertaining to said first topic, thereby informing said publisher component of said plurality of client devices to which said at least one of messages and content pertaining to said first topic was sent;
obtaining at said publisher component, from each of said client devices that received said at least one of messages and content, one of said N random numbers corresponding to that client device; and
using said random numbers obtained from said client devices and re-published by said interceptor component, said publisher component determining particular messages and/or content to be re-published to selected ones of said client devices.
5 Assignments
0 Petitions
Accused Products
Abstract
A plurality of subscribers are registered to receive, from a publisher component, at client devices, via a broker component, at least one of messages and content pertaining to a first topic. Each of the subscribers is caused to generate one of N random numbers. A different one of the N random numbers is generated by each of the subscribers. Each of the subscribers is instructed to listen only for the messages and content pertaining to the first topic and corresponding to the corresponding one of the N random numbers. The at least one of messages and content pertaining to the first topic are published to those of the subscribers associated with each one of the N random numbers, number by number, until the at least one of messages and content pertaining to the first topic has been published to all of the plurality of subscribers.
-
Citations
16 Claims
-
1. A method comprising the steps of:
-
registering a plurality of client devices to receive, from a publisher component, via a broker component, at least one of messages and content pertaining to a first topic; causing each of said client devices to generate one of N random numbers, a different one of N random numbers being generated by each of said client devices; instructing each of said client devices to listen only for said at least one of messages and content pertaining to said first topic and corresponding to said one of N random numbers generated by each corresponding one of said client devices; publishing said at least one of messages and content pertaining to said first topic from said publisher component, via said broker component, to those of said client devices associated with each one of said N random numbers, number by number, until said at least one of messages and content pertaining to said first topic has been published to all of said plurality of client devices; listening, at an interceptor component, for said at least one of messages and content pertaining to a first topic published from the publisher component to the plurality of client devices, via the broker component, said least one of messages and content including a uniform resource locator of said publisher component; intercepting said at least one of messages and content pertaining to said first topic with said interceptor component; re-publishing, with said interceptor component, to a second topic different than said first topic, said random numbers corresponding to destination client devices for each of said intercepted at least one of messages and content pertaining to said first topic, thereby informing said publisher component of said plurality of client devices to which said at least one of messages and content pertaining to said first topic was sent; obtaining at said publisher component, from each of said client devices that received said at least one of messages and content, one of said N random numbers corresponding to that client device; and using said random numbers obtained from said client devices and re-published by said interceptor component, said publisher component determining particular messages and/or content to be re-published to selected ones of said client devices. - View Dependent Claims (2, 3, 4, 5, 6, 7, 16)
-
-
8. A publisher apparatus comprising:
-
a memory; and at least one processor, coupled to said memory and operative to; register a plurality of client devices to receive, from said publisher apparatus, via a broker component, at least one of messages and content pertaining to a first topic; cause each of said client devices to generate one of N random numbers, a different one of N random numbers being generated by each of said client devices; instruct each of said client devices to listen only for said at least one of messages and content pertaining to said first topic and corresponding to said one of N random numbers generated by each corresponding one of said client devices; publish said at least one of messages and content pertaining to said first topic to those of said client devices associated with each one of said N random numbers, number by number, until said at least one of messages and content pertaining to said first topic has been published to all of said plurality of client devices; receive, from an interceptor component, those of said N random numbers that correspond to destination client devices to which said at least one of messages and content pertaining to said first topic was sent; obtain from each of said client devices that received said at least one of messages and content, one of said N random numbers corresponding to that client device; and using said random numbers obtained from said client devices and received from said interceptor component, determine particular messages and/or content to be re-published to selected ones of said client devices. - View Dependent Claims (9, 10, 11)
-
-
12. An article of manufacture comprising a tangible non-transitory machine readable recordable storage medium with instructions recorded thereon which, when executed by a processor, cause said processor to be operative to:
-
register a plurality of client devices to receive, from said publisher apparatus, via a broker component, at least one of messages and content pertaining to a first topic; cause each of said client devices to generate one of N random numbers, a different one of N random numbers being generated by each of said client devices; instruct each of said client devices to listen only for said at least one of messages and content pertaining to said first topic and corresponding to said one of N random numbers generated by each corresponding one of said client devices; publish said at least one of messages and content pertaining to said first topic to those of said client devices associated with each one of said N random numbers, number by number, until said at least one of messages and content pertaining to said first topic has been published to all of said plurality of client devices; receive, from an interceptor component, those of said N random numbers that correspond to destination client devices to which said at least one of messages and content pertaining to said first topic was sent; obtain from each of said client devices that received said at least one of messages and content, one of said N random numbers corresponding to that client device; and using said random numbers obtained from said client devices and received from said interceptor component, determine particular messages and/or content to be re-published to selected ones of said client devices. - View Dependent Claims (13, 14, 15)
-
Specification