Forwarding multicast messages in a messaging network

Patent metadata

Field	Value
Publication number	US-9112824-B2
Application number	US-201313839109-A
Country	US
Kind code	B2
Filing date	Mar 15, 2013
Priority date	Mar 15, 2013
Publication date	Aug 18, 2015
Grant date	Aug 18, 2015

Abstract

The subject matter of this specification can be implemented in, among other things, a method that includes establishing federation links between a message broker system and neighbors of the message broker system. The method includes identifying shortest paths between the message broker system and other message broker systems. The method includes receiving a request to forward a message from a source message broker system to destination message broker systems. The method includes identifying source paths between the source message broker system and the message broker system, intermediate message broker systems along the source paths, and destination paths between the message broker system and remaining ones of the destination message broker systems that neighbor the message broker system other than ones of the intermediate message broker systems. The method includes delivering the multicast message to the remaining ones of the destination message broker systems.

First claim

What is claimed is:

1. A method comprising:
establishing, at a message broker system among multiple message broker systems in a message bus, first federation links between the message broker system and ones of the message broker systems that neighbor the message broker system;
distributing, from the message broker system, information describing the first federation links to others of the message broker systems;
receiving, at the message broker system, information describing second federation links between each of the others of the message broker systems and ones of the others of the message broker systems that neighbor each of the others of the message broker systems;
identifying shortest paths through the message bus between the message broker system and each of the others of the message broker systems based on the first federation links and the second federation links;
receiving, at the message broker system from a source message broker system among the message broker systems, a request to forward a multicast message from the source message broker system through the message bus to multiple destination message broker systems among the message broker systems;
identifying, at the message broker system, source paths from among the shortest paths between the source message broker system and the message broker system;
identifying, at the message broker system, intermediate message broker systems from among the message broker systems along the source paths; and
delivering, from the message broker system, the multicast message to remaining ones of the destination message broker systems that neighbor the message broker system other than ones of the intermediate message broker systems.

2. The method of claim 1 , wherein the message bus uses a protocol that is an extension of the Advanced Message Queuing Protocol.

3. The method of claim 1 , wherein the multicast message is a broadcast message.

4. The method of claim 1 , wherein delivering the multicast messages occurs without delivering the multicast message to ones of the destination message broker systems that neighbor the message broker system and are among the intermediate message broker systems.

5. The method of claim 4 , further comprising identifying, at the message broker system, destination paths from among the shortest paths between the message broker system and the destination message broker systems, wherein delivering the multicast message comprises delivering the multicast message to the remaining ones of the destination message broker systems that neighbor the message broker system and are along the destination paths other than the ones of the intermediate message broker systems.

6. The method of claim 5 , wherein delivering the multicast messages occurs without delivering the multicast message to the remaining ones of the destination message broker systems that neighbor the message broker system and are not along the destination paths.

7. A non-transitory computer-readable medium having instructions stored thereon, which when executed by a processing device, cause the processing device to perform operations comprising:
establishing, at a message broker system among multiple message broker systems in a message bus, first federation links between the message broker system and ones of the message broker systems that neighbor the message broker system;
distributing, from the message broker system, information describing the first federation links to others of the message broker systems;
receiving, at the message broker system, information describing second federation links between each of the others of the message broker systems and ones of the others of the message broker systems that neighbor each of the others of the message broker systems;
identifying shortest paths through the message bus between the message broker system and each of the others of the message broker systems based on the first federation links and the second federation links;
receiving, at the message broker system from a source message broker system among the message broker systems, a request to forward a multicast message from the source message broker system through the message bus to multiple destination message broker systems among the message broker systems;
identifying, at the message broker system, source paths from among the shortest paths between the source message broker system and the message broker system;
identifying, at the message broker system, intermediate message broker systems from among the message broker systems along the source paths; and
delivering, from the message broker system, the multicast message to remaining ones of the destination message broker systems that neighbor the message broker system other than ones of the intermediate message broker systems.

8. The computer-readable medium of claim 7 , wherein the message bus uses a protocol that is an extension of the Advanced Message Queuing Protocol.

9. The computer-readable medium of claim 7 , wherein the multicast message is a broadcast message.

10. The computer-readable medium of claim 7 , wherein delivering the multicast messages occurs without delivering the multicast message to ones of the destination message broker systems that neighbor the message broker system and are among the intermediate message broker systems.

11. The computer-readable medium of claim 10 , further comprising identifying, at the message broker system, destination paths from among the shortest paths between the message broker system and the destination message broker systems, wherein delivering the multicast message comprises delivering the multicast message to the remaining ones of the destination message broker systems that neighbor the message broker system and are along the destination paths other than the ones of the intermediate message broker systems.

12. The computer-readable medium of claim 11 , wherein delivering the multicast messages occurs without delivering the multicast message to the remaining ones of the destination message broker systems that neighbor the message broker system and are not along the destination paths.

13. A system comprising:
an interface, coupled to a message bus that includes message broker systems, to establish first federation links between a message broker system and ones of the message broker systems that neighbor the message broker system, to distribute information describing the first federation links to others of the message broker systems, to receive information describing second federation links between each of the others of the message broker systems and ones of the others of the message broker systems that neighbor each of the others of the message broker systems, and to receive a request to forward a multicast message from a source message broker system among the message broker systems through the message bus to multiple destination message broker systems among the message broker systems; and
a processing device to identify shortest paths through the message bus between the message broker system and each of the others of the message broker systems based on the first federation links and the second federation links, to identify source paths from among the shortest paths between the source message broker system and the message broker system, to identify intermediate message broker systems from among the message broker systems along the source paths, and to deliver the multicast message to remaining ones of the destination message broker systems that neighbor the message broker system other than ones of the intermediate message broker systems.

14. The system of claim 13 , wherein the message bus uses a protoc

Assignees

• Red Hat Inc

Inventors

• Ross Theodore Langston

Classifications

• H04L45/122

  by minimising distances, e.g. by selecting a route with minimum of number of hops · CPC title

• H04L45/28

  using route fault recovery · CPC title

• H04L12/18 Primary

  for broadcast or conference {, e.g. multicast} · CPC title

• H04L45/16

  Multipoint routing · CPC title

• H04L51/14 Primary

  Electricity · mapped topic