主权项 |
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. |