Dynamic subscription and message routing on a topic between publishing nodes and subscribing nodes
First Claim
1. A computerized method for publishing a message in a publish/subscribe architecture having at least one publisher, a plurality of subscribers, and plurality of brokers, the method comprising:
- receiving a plurality of subscription requests at the plurality of brokers;
consolidating the received plurality of subscription requests;
determining whether to propagate the consolidated subscriptions requests;
receiving the message and a topic at a broker via a network;
identifying at least one subscriber for the topic received;
determining a path for sending the message via the network, including performing real-time adjustment of the path; and
sending the message to the identified subscribers,wherein performing real-time adjustment of the path comprises;
monitoring changes to a topology of the network;
determining in real-time whether any connections are not available; and
automatically calculating a best path for any subscribers affected by an unavailable connection.
3 Assignments
0 Petitions
Accused Products
Abstract
A system for dynamic message routing on a topic between publishing nodes and subscribing nodes includes a plurality of message queues, at least one topic/node table, a subscribing module, a publishing module, and other modules to send messages between one or more publisher and one or more subscribers. These modules are coupled together by a bus in a plurality of nodes and provide for the dynamic message routing on a topic between publishing nodes and subscribing nodes. The message queues store messages at each node for delivery to subscribers local to that node. The topic/node table lists which clients subscribe to which topics, and is used by the other modules to ensure proper distribution of messages. The subscribing module is use to establish a subscription to a topic for that node. The publishing module is used to identify subscribers to a topic and transmit messages to subscribers dynamically. The other modules include various devices to optimize message communication in a publish/subscribe architecture operating on a distributed computing system. The present invention also includes a number of novel methods including: a method for publishing a message on a topic, a method for forwarding a message on a topic, a method for subscribing to messages on a topic, a method for automatically removing subscribers, a method for direct publishing of messages, and methods for optimizing message transmission between nodes.
20 Citations
19 Claims
-
1. A computerized method for publishing a message in a publish/subscribe architecture having at least one publisher, a plurality of subscribers, and plurality of brokers, the method comprising:
-
receiving a plurality of subscription requests at the plurality of brokers; consolidating the received plurality of subscription requests; determining whether to propagate the consolidated subscriptions requests; receiving the message and a topic at a broker via a network; identifying at least one subscriber for the topic received; determining a path for sending the message via the network, including performing real-time adjustment of the path; and sending the message to the identified subscribers, wherein performing real-time adjustment of the path comprises; monitoring changes to a topology of the network; determining in real-time whether any connections are not available; and automatically calculating a best path for any subscribers affected by an unavailable connection. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19)
-
Specification