Dynamic subscription and message routing on a topic between publishing nodes and subscribing nodes
AssigneeAurea Software, Inc.
InventorWilliam Cullen
Life of this patent
Estimating the term…
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. Methods include: 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.
Claims38
A method for dynamic message routing between publishing nodes and subscribing nodes sent throughout a network without regard to how a topology of the network changes, the method comprising:
- executing a program by a computer system that transforms the computer system into a machine to perform:
- receiving a plurality of subscription requests at a 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 one or more subscribers for the topic received;
- obtaining up-to-date network path configuration information;
- reconfiguring broker network path information based on revisions to the network path configuration information to determine 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 the topology of the network;
- determining in real-time whether any connections within the network are unavailable to dynamically maintain subscriptions;
- and
- automatically calculating a path for any subscribers affected by any unavailable connections.
An apparatus for dynamic message routing between publishing nodes and subscribing nodes sent throughout a network without regard to how a topology of the network changes, the apparatus comprising:
- a processor;
- and
- a memory, coupled to the processor, having code and data stored therein, wherein the code is executable by the processor to transform the apparatus into a machine to:
- receive a plurality of subscription requests at a plurality of brokers;
- consolidate the received plurality of subscription requests;
- determining whether to propagate the consolidated subscriptions requests;
- receive the message and a topic at a broker via a network;
- identify one or more subscribers for the topic received;
- obtain up-to-date network path configuration information;
- reconfigure broker network path information based on revisions to the network path configuration information to determine 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 to perform real-time adjustment of the path comprises to:
- monitor changes to the topology of the network;
- determine in real-time whether any connections within the network are unavailable to dynamically maintain subscriptions;
- and
- automatically calculate a path for any subscribers affected by any unavailable connections.
Dependencies are inferred from the claim text.