Publish/subscribe message routing

• US 8,756,288 B2
• Filed: 02/10/2012
• Issued: 06/17/2014
• Est. Priority Date: 03/11/2011
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bedi, Bharat V., Bowyer, Helen S., Brown, Kevin C., Jellard, Edward G., Smart, Robert S., White, Graham
• Primary Examiner(s): Bates, Kevin
• Assistant Examiner(s): Patel, Ronak
• Application Number:
  US13/370,822
• Publication Number:
  US 20120233268A1
• Time in Patent Office: 858 Days
• Field of Search: 709/206
• US Class Current: 709/206
• CPC Class Codes: H04L 51/214 using selective forwarding

Abstract

Message routing in a publish/subscribe system where messages are routed from one or more publishers to one or more subscribers according to respective defined paths through a topic tree. A pseudo-topic tree path comprised of a partial path definition and a selection function is specified by a subscriber or publisher. When executed, the selection function searches the topic tree to identify one or more path definition segments, which segments replace the selection function in the pseudo-topic tree path to generate one or more complete path definitions that are then usable for routing messages.

Claims

1. An apparatus in a publish/subscribe messaging environment for routing messages received from at least a first publisher to one or more subscribers according to one or more defined paths through a topic tree that defines topics for routing the messages, the apparatus comprising:

a processor;

a memory coupled with the processor and holding data defining the topic tree;

a first message handler for receiving a message, the message including selection function data defining a selection function, with the handler being adapted to identify and extract the selection function data and store the extracted selection function data in the data defining the topic tree;

a further message handler adapted to create, from the received message, a pseudo-topic tree path comprised of a partial path definition and a representation of the selection function;

a search engine coupled with the memory and adapted to search the data defining the topic tree, according to the selection function, and to return one or more path definition segments resulting from the search;

an inserter coupled with the further message handler and the search engine and adapted to insert each of the one or more returned path definition segments into respective copies of the pseudo-topic tree path, in place of the representation of the selection function, to produce one or more complete path definitions from the partial path definition; and

a matching engine coupled with the inserter and adapted to route messages according to each of the one or more produced complete path definitions.

2. An apparatus as claimed in claim 1, wherein:

a first subscriber subscribes to a pseudo-topic by originating the message including the selection function data defining the selection function of which a particular pseudo-topic tree path representing the pseudo-topic is comprised; and

the matching engine is adapted to route, to the first subscriber, all messages having a topic that matches any of the one or more produced complete path definitions.

3. An apparatus as claimed in claim 1, wherein:

a first publisher establishes a pseudo-topic by originating the message including the selection function data defining the selection function of which a particular pseudo-topic tree path representing the pseudo-topic is comprised; and

the matching engine is adapted to route, from the first publisher, all messages having a topic that matches any of the one or more produced complete path definitions.

4. An apparatus as claimed in claim 1, wherein:

the search engine is adapted to periodically perform the search of the data defining the topic tree, in respect of each stored selection function; and

the matching engine is adapted to route existing messages to subscribers to topics matching any complete path definition produced as a result of the periodically-performed search.

5. An apparatus as claimed in claim 4, wherein the search engine is adapted to perform the search responsive to detecting that the data defining the topic tree is modified.

6. An apparatus as claimed in claim 1, wherein the first message handler is adapted to, on receipt of a predetermined command, modify or delete stored selection function data for a particular selection function identified in the predetermined command.

7. An apparatus as claimed in claim 1, wherein the first message handler is adapted to store the selection function data in a predetermined location within the data defining the topic tree.

8. A computer-implemented method of message routing in a publish/subscribe messaging environment where messages are routed from one or more publishers to one or more subscribers according to respective defined paths through a topic tree that defines topics for routing the messages, comprising:

creating a pseudo-topic tree path comprised of a partial path definition and a representation of a selection function, wherein the selection function, when executed, searches the topic tree to identify one or more path definition segments;

replacing the representation of the selection function in the pseudo-topic tree path with respective ones of the identified one or more path definition segments to generate one or more complete path definitions; and

routing messages according to the one or more generated complete path definitions.

9. A method as claimed in claim 8, wherein a first subscriber subscribes to a pseudo-topic by originating the selection function used to create the pseudo-topic tree path representing the pseudo-topic, and responsive to the subscribing, all messages having a topic defined by any of the one or more generated complete path definitions are routed to the first subscriber.

10. A method as claimed in claim 9, wherein a second subscriber subscribes to a pseudo-topic originated by the first subscriber, and responsive to the subscribing by the second subscriber, all messages having a topic defined by any of the one or more generated complete path definitions are routed to the second subscriber.

11. A method as claimed in claim 8, wherein a first publisher establishes a pseudo-topic by originating the selection function used to create the pseudo-topic tree path representing the pseudo-topic, and responsive to the establishing, all messages published to the pseudo-topic by the first publisher are published to topics identified by the one or more generated complete path definitions.

12. A method as claimed in claim 11, wherein, responsive to receipt of a request from a second publisher, messages from the second publisher are published to subscribers to topics identified by the pseudo-topic established by the first publisher.

13. A method as claimed in claim 8, wherein the searching of the topic tree is performed periodically, in respect of each of at least one selection function, and existing messages are routed to subscribers to topics identified by any complete path definition that is generated by executing the replacing using the one or more path definition segments that are identified by the periodic search.

14. A method as claimed in claim 13, wherein the search is performed responsive to detecting that the topic tree is modified.

15. A computer program stored on a non-transitory computer readable medium and loadable into an internal memory of a digital computer, the computer program comprising software code portions which are executable, when the computer program is run on the digital computer, for enabling messages from one or more publishers to be routed to one or more subscribers according to defined paths through a topic tree that defines topics for routing the messages, in a publish/subscribe messaging environment, comprising:

creating a pseudo-topic tree path comprised of a partial path definition and a representation of a selection function, wherein the selection function, when executed, searches the topic tree to identify one or more path definition segments;

replacing the representation of the selection function in the pseudo-topic tree path with respective ones of the identified one or more path definition segments to generate one or more complete path definitions; and

routing messages according to the one or more generated complete path definitions.