Handling unavailable destinations in a messaging network

摘要

The subject matter of this specification can be implemented in, among other things, a method that includes establishing first federation links between a message broker system and neighbors of the message broker system. The method further includes distributing information describing the first federation links to other message broker systems. The method further includes receiving information describing second federation links between each of the other message broker systems and neighbors of each of the other message broker system. The method further includes identifying shortest paths between the message broker system and each of the other message broker systems. The method further includes receiving a request to send a message from a source message broker system to a destination message broker system. The method further includes determining that none of the shortest paths to the destination message broker system are available and, in response, taking corrective action.

主权项

1. A method comprising:
identifying, by a processor of a message broker system among multiple message broker systems in a message bus, shortest paths through the message bus between the message broker system and others of the message broker systems in view of first federation links between the message broker system and ones of the other of the message broker systems that neighbor the message broker system and in view of second federation links between each of the others of the message broker systems and ones of the message broker systems that neighbor each of the others of the message broker systems; receiving, at the message broker system, a request to send a message from a source message broker system among the message broker systems through the message bus to a destination message broker system among the message broker systems; determining, by the processor of the message broker system, that none of the shortest paths to the destination message broker system are available; and initiating, by the processor of the message broker system, corrective action in view of determining that none of the shortest paths to the destination message broker system are available.