Publish-subscribe messaging in a content network

• US 10,868,874 B2
• Filed: 05/14/2017
• Issued: 12/15/2020
• Est. Priority Date: 01/21/2014
• Status: Active Grant

• Current Assignee: Time Warner Cable Enterprises LLC (Charter Communications Incorporated)
• Original Assignee: Time Warner Cable Enterprises LLC (Charter Communications Incorporated)
• Inventors: Horton, Gary
• Primary Examiner(s): Yohannes, Tesfay
• Application Number:
  US15/594,635
• Publication Number:
  US 20170264696A1
• Time in Patent Office: 1,311 Days
• Field of Search: 709204, 709206, 4554042
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 67/51 Discovery or management thereof, e.g. service location protocol [SLP] or web services

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.

Claims

1. A computer-implemented method comprising:

listening, by an interceptor component that is implemented in a first processor, for at least one of messages and content pertaining to a first topic published to a plurality of client devices from a publisher component that is implemented in the first processor or in a second processor, via a broker component that is connected in communication between said publisher component and said client devices;

intercepting from said broker component, by said interceptor component, said at least one of messages and content pertaining to said first topic; and

reducing unnecessary network traffic by informing said publisher component of said plurality of client devices to whom said at least one of messages and content pertaining to said first topic was sent, by re-publishing to said broker component, by said interceptor component, identifying information for a destination client device for each of said intercepted at least one of messages and content pertaining to said first topic.

2. The method of claim 1, wherein said at least one of messages and content comprises content.

3. The method of claim 2, wherein said content comprises a uniform resource locator identifying a cloud-based user interface.

4. The method of claim 1, wherein said at least one of messages and content comprises a uniform resource locator of said publisher component.

5. The method of claim 1, wherein re-publishing includes re-publishing to a second topic different than said first topic.

6. The method of claim 1, wherein re-publishing includes re-publishing by said interceptor component back to said broker component for transmission to said publisher component.

7. An interceptor apparatus comprising:

a memory embodying computer-executable instructions; and

at least one processor, coupled to said memory and operative by said computer-executable instructions to;

listen for at least one of messages and content pertaining to a first topic published from a publisher component to a plurality of client devices, via a broker component that is connected in communication between said publisher component and said client devices;

intercept from said broker component said at least one of messages and content pertaining to said first topic; and

reduce unnecessary network traffic by informing said publisher component of said plurality of client devices to whom said at least one of messages and content pertaining to said first topic was sent, by re-publishing to said broker component identifying information for a destination client device for each of said intercepted at least one of messages and content pertaining to said first topic.

8. The apparatus of claim 7, wherein said at least one of messages and content comprises content.

9. The apparatus of claim 7, wherein said content comprises a uniform resource locator identifying a cloud-based user interface.

10. The apparatus of claim 7, wherein said at least one of messages and content comprises a uniform resource locator of said publisher component.

11. The apparatus of claim 7, wherein re-publishing includes re-publishing to a second topic different than said first topic.

12. The apparatus of claim 7, wherein re-publishing includes re-publishing by said interceptor apparatus back to said broker component for transmission to said publisher component.

13. A non-transitory computer-readable recordable storage medium embodying computer-executable instructions which when executed by a processor cause the processor to facilitate a method comprising:

listening for at least one of messages and content pertaining to a first topic published from a publisher component to a plurality of client devices, via a broker component that is connected in communication between said publisher component and said client devices;

intercepting from said broker component said at least one of messages and content pertaining to said first topic; and

reducing unnecessary network traffic by informing said publisher component of said plurality of client devices to whom said at least one of messages and content pertaining to said first topic was sent, by re-publishing to said broker component identifying information for a destination client device for each of said intercepted at least one of messages and content pertaining to said first topic.

14. The medium of claim 13, wherein said at least one of messages and content comprises content.

15. The medium of claim 14, wherein said content comprises a uniform resource locator identifying a cloud-based user interface.

16. The medium of claim 13, wherein said at least one of messages and content comprises a uniform resource locator of said publisher component.

17. The medium of claim 13, wherein re-publishing includes re-publishing to a second topic different than said first topic.

18. The medium of claim 13, wherein re-publishing includes re-publishing back to said broker component for transmission to said publisher component.