Data Streaming Service with Virtualized Broker Clusters
US-2024223674-A1 · Jul 4, 2024 · US
US12363059B2 · US · B2
| Field | Value |
|---|---|
| Publication number | US-12363059-B2 |
| Application number | US-202318394902-A |
| Country | US |
| Kind code | B2 |
| Filing date | Dec 22, 2023 |
| Priority date | Jul 31, 2023 |
| Publication date | Jul 15, 2025 |
| Grant date | Jul 15, 2025 |
A practical reading order for non-experts. Skip the full description unless you need deep technical detail.
What the patent document calls the invention.
A short plain-language summary of the technical disclosure.
Who owns or filed the patent and who is credited as inventor.
Filing, priority, publication, and grant dates set the timeline.
The legal scope of protection — read this for what is actually claimed.
Technology tags used to group this patent with similar filings.
Prior art links and similar publications in this corpus.
Official abstract text for this publication.
A messaging system is provided to communicate messages between computing devices. The computing devices can include vehicles and service computers. The messaging system includes nodes and virtual entities that may forward messages between computing devices. The messaging system may be a publish-subscribe system. The messaging system may allocate a allocating virtual entities that are associated with the computing devices. The virtual entity may be endpoints for the messages.
Opening claim text (preview).
What is claimed is: 1. A method, comprising: receiving a request, from a computing device, to connect to a publish-subscribe (pub-sub) system, wherein the pub-sub system comprises a plurality of nodes to process messages for the pub-sub system; allocating a virtual entity associated with the computing device in response to receiving the request to connect to the pub-sub system, wherein the virtual entity comprises an endpoint for the messages, wherein the messages comprise a first message published to a first topic of the pub-sub system and a second message addressed to the virtual entity, and wherein the virtual entity is located in a first node of the plurality of nodes; and forwarding the messages between the computing device and other computing devices via the virtual entity. 2. The method of claim 1 , further comprising: selecting the first node from the plurality of nodes based on one or more node selection criterion. 3. The method of claim 1 , wherein a network connection exists between the computing device and the first node. 4. The method of claim 1 , further comprising: determining that the computing device should be moved to a second node of the plurality of nodes; and allocating a second virtual entity associated with the computing device, wherein the second virtual entity comprises an endpoint for the messages and wherein the second virtual entity is located in second node. 5. The method of claim 1 , wherein the virtual entity is associated with an identifier that is unique within the pub-sub system. 6. The method of claim 1 , further comprising: receiving a message for the computing device from another computing device via the pub-sub system; and transmitting the message to the computing device via the first virtual entity. 7. The method of claim 1 , further comprising: receiving a message from the computing device for another computing device; and transmitting the message to the other computing device via the first virtual entity and the pub-sub system. 8. The method of claim 1 , wherein the messages comprises one or more of: a message for subscribing the computing device to a topic; and a message published by another computing device for the topic. 9. The method of claim 1 , wherein the computing device comprises a vehicle or a server computer. 10. A apparatus, comprising: a memory; and a processing device, communicatively coupled to the memory, the processing device configured to: receive a request, from a computing device, to connect to a publish-subscribe (pub-sub) system, wherein the pub-sub system comprises a plurality of nodes to process messages for the pub-sub system; allocate a virtual entity associated with the computing device in response to receiving the request to connect to the pub-sub system, wherein the virtual entity comprises an endpoint for the messages, wherein the messages comprise a first message published to a first topic of the pub-sub system and a second message addressed to the virtual entity, and wherein the virtual entity is located in a first node of the plurality of nodes; and forward the messages between the computing device and other computing devices via the virtual entity. 11. The apparatus of claim 10 , wherein the processing device is further configured to: select the first node from the plurality of nodes based on one or more node selection criterion. 12. The apparatus of claim 10 , wherein a network connection exists between the computing device and the first node. 13. The apparatus of claim 10 , wherein the processing device is further configured to: determine that the computing device should be moved to a second node of the plurality of nodes; and allocate a second virtual entity associated with the computing device, wherein the second virtual entity comprises an endpoint for the messages and wherein the second virtual entity is located in second node. 14. The apparatus of claim 10 , wherein the virtual entity is associated with an identifier that is unique within the pub-sub system. 15. The apparatus of claim 10 , wherein the processing device is further configured to: receive a message for the computing device from another computing device via the pub-sub system; and transmit the message to the computing device via the first virtual entity. 16. The apparatus of claim 10 , wherein the processing device is further configured to: receive a message from the computing device for another computing device; and transmit the message to the other computing device via the first virtual entity and the pub-sub system. 17. The apparatus of claim 10 , wherein the messages comprises one or more of: a message for subscribing the computing device to a topic; and a message published by another computing device for the topic. 18. The apparatus of claim 10 , wherein the computing device comprises a vehicle or a server computer. 19. The apparatus of claim 10 , wherein the apparatus further comprises the pub-sub system. 20. A non-transitory computer-readable storage medium including instructions that, when executed by a processing device, cause the processing device to perform operations comprising: receiving a request, from a computing device, to connect to a publish-subscribe (pub-sub) system, wherein the pub-sub system comprises a plurality of nodes to process messages for the pub-sub system; allocating a virtual entity associated with the computing device in response to receiving the request to connect to the pub-sub system, wherein the virtual entity comprises an endpoint for the messages, wherein the messages comprise a first message published to a first topic of the pub-sub system and a second message addressed to the virtual entity, and wherein the virtual entity is located in a first node of the plurality of nodes; and forwarding the messages between the computing device and other computing devices via the virtual entity.
Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources (admission control or resource allocation H04L47/70) · CPC title
characterised by the inclusion of specific contents · CPC title
for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS] · CPC title
Brokering proxy services · CPC title
Monitoring or handling of messages · CPC title
Related publications grouped by family.
Answers are generated from the same data shown on this page.