Bridge for linking two publish/subscribe message brokers
View Patent ↗The invention discloses a subscription which is made to receive request messages on one or more topics from a first broker. A subscription is made to receive all messages published at either the first or the second broker to a replyto topic including a bridge identifier. A request message is received from the first broker, the request message specifying a temporary replyto topic on which responses to the request should be published. The temporary reply to topic is modified to specify a bridge identifier. The modified request message is forwarded to a second broker. A response to the request is received from the second broker, the response being published on the replyto topic including the bridge identifier. The bridge receives the response as a result of the subscription to receive all messages published to a topic including the bridge identifier. The response is forwarded to the first broker.
1. A bridge configured to link together two publish/subscribe message brokers, comprising:
a processor, wherein the processor is configured to perform
subscribing to receive request messages on one or more topics from a first publish/subscribe message broker;
subscribing to receive all messages published at both the first publish/subscribe message broker and a second publish/subscribe message broker to a replyto topic that includes a bridge identifier of the bridge;
receiving a request message from the first publish/subscribe message broker, the request message specifying a temporary replyto topic;
modifying the temporary replyto topic to specify the bridge identifier;
forwarding the modified request message to the second publish/subscribe message broker;
receiving a response message to the modified request message from the second publish/subscribe message broker, the response message including the bridge identifier; and
forwarding the response message to the first publish/subscribe message broker.
2. The bridge of claim 1 , wherein the processor is further configured to consulting a mapping table to determine where to forward the response message.
3. The bridge of claim 1 , wherein
the modified request message includes routing information to route the response message to the first publish/subscribe broker.
4. The bridge of claim 1 , wherein
the modified request message includes an unmodified temporary replyto topic.
5. The bridge of claim 4 , wherein the processor is further configured to
modifying the response message to refer to the unmodified temporary replyto topic prior to the response message being forwarded to the first publish/subscribe message broker.
6. A computer program product comprising a computer usable storage medium having stored therein computer usable program code for linking together two publish/subscribe message brokers, the computer usable program code, which when executed by a computer hardware system, causes the computer hardware system to perform:
subscribing to receive request messages on one or more topics from a first publish/subscribe message broker;
subscribing to receive all messages published at both the first publish/subscribe message broker and a second publish/subscribe message broker to a replyto topic that includes a bridge identifier of a bridge;
receiving a request message from the first publish/subscribe message broker, the request message specifying a temporary replyto topic;
modifying the temporary replyto topic to specify the bridge identifier;
forwarding the modified request message to the second publish/subscribe message broker;
receiving a response message to the modified request message from the second publish/subscribe message broker, the response message including the bridge identifier; and
forwarding the response message to the first publish/subscribe message broker.
7. The computer program product of claim 6 , wherein the computer usable program code further causes the computer hardware system to perform
consulting a mapping table to determine where to forward the response message.
8. The computer program product of claim 6 , wherein
the modified request message includes routing information to route the response message to the first publish/subscribe broker.
9. The computer program product of claim 6 , wherein
the modified request message includes an unmodified temporary replyto topic.
10. The computer program product of claim 9 , wherein the computer usable program code further causes the computer hardware system to perform
modifying the response message to refer to the unmodified temporary replyto topic prior to the response message being forwarded to the first publish/subscribe message broker.