Routing messages exclusively to eligible consumers in a dynamic routing network

• US 9,313,159 B2
• Filed: 03/24/2011
• Issued: 04/12/2016
• Est. Priority Date: 03/24/2011
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Ross, Theodore L.
• Primary Examiner(s): Park, Jeong S
• Application Number:
  US13/071,277
• Publication Number:
  US 20120246337A1
• Time in Patent Office: 1,846 Days
• Field of Search: 709238-244
• US Class Current: 1/1
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 45/308 Route determination based on user's profile, e.g. premium users
• CPC Class Codes: H04L 45/42 Centralised routing
• CPC Class Codes: H04L 45/44 Distributed routing
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/63 Routing a service request depending on the request content or context

Abstract

Embodiments relate to routing a message only along routes in a messaging network that lead to a currently active consumer for the message. The messaging network adapts to changes in the message preferences of the message consumer, and the message consumer'"'"'s availability throughout the messaging network. In various embodiments, changes to message routing criteria at a destination broker in the network are propagated to all other brokers in the network until the entire network is adapted, and the network routes messages based on the adaptations, which reflect the current connectivity and message accepting criteria of each message consumer.

Claims

1. A method comprising:

storing, by a central processing unit, routing information for each of a plurality of message consumers connected to a messaging network, the routing information comprising an identification number (IN) that is associated with a first message consumer of the plurality of message consumers, the messaging network comprising a plurality of brokers;

receiving a message and metadata associated with the message from a message producer without identification or an address of an intended message consumer, wherein the metadata comprises a routing key attached to the message;

comparing, by the central processing unit, the routing key to the routing information for each of the plurality message consumers connected to the messaging network via the plurality of brokers;

determining, by the central processing unit and in view of the comparing, that a broker of the plurality of brokers in the messaging network is connected to the first message consumer of the plurality of message consumers when the routing key corresponds to the IN, wherein the central processing unit is in data communication with the broker via the messaging network; and

routing, by the central processing unit, the message to the broker that is connected to the first message consumer that is associated with the IN.

2. The method of claim 1, further comprising:

determining, by the central processing unit and in view of the comparing, whether there is a second message consumer of the plurality of message consumers that is directly connected to a computing system that comprises the central processing unit that can receive the message; and

routing, by the central processing unit, the message to the second message consumer that was determined when the message consumer can receive the message.

3. The method of claim 1, wherein the metadata associated with the message comprises a topic assigned to the message by a producer of the message.

4. The method of claim 1, wherein the message comprises content, and wherein the routing information comprises information that must match corresponding information in the content of the message, and wherein the information that must match is specified by the message consumer.

5. The method of claim 1, wherein storing routing information for each message consumer comprises:

updating the routing information for a message consumer of the plurality of message consumers that changes a connection status with the messaging network.

6. A system comprising:

a memory to contain instructions; and

a central processing unit, operatively coupled to the memory, to execute the instructions to;

maintain routing information for each of a plurality of message consumers connected to a messaging network, the routing information comprising an identification number (IN) that is associated with a first message consumer of the plurality of message consumers, the messaging network comprising a plurality of brokers;

receive a message and metadata associated with the message from a message producer without identification or an address of an intended message consumer, wherein the metadata comprises a routing key attached to the message;

compare the routing key to the routing information for each of the plurality of message consumers connected to the messaging network via the plurality of brokers;

determine, in view of the comparing, that a broker of the plurality of brokers is connected to the first message consumer of the plurality of message consumers when the routing key corresponds to the IN, wherein the central processing unit is in data communication with the broker via the messaging network; and

route the message to the broker that is connected to the first message consumer that is associated with the IN.

7. The system of claim 6, the central processing unit further to:

determine, in view of the comparing, whether there is a second message consumer of the plurality of message consumers that is directly connected to a computing system that can receive the message; and

route the message to the message consumer that was determined when the second message consumer can receive the message.

8. The system of claim 6, wherein the metadata associated with the message comprises a topic assigned to the message by a producer of the message.

9. The system of claim 6, wherein the message comprises content, and wherein the routing information comprises information that must match corresponding information in the content of the message, and wherein the information that must match is specified by the message consumer.

10. The system of claim 6, wherein when maintaining routing information for each message consumer, the central processing unit to:

update the routing information for a message consumer of the plurality of message consumers that changes a connection status with the messaging network.

11. A non-transitory computer-readable medium comprising instructions that, when executed by a central processing unit, cause the central processing unit to:

store routing information for each of a plurality of message consumers connected to a messaging network, the routing information comprising an identification number (IN) that is associated with a first message consumer of the plurality of message consumers, the messaging network comprising a plurality of brokers;

receive a message and metadata associated with the message from a message producer without identification or an address of an intended message consumer, wherein the metadata comprises a routing key attached to the message;

compare, by the central processing unit, the routing key to the routing information for each message consumer of the plurality of message consumers connected to the messaging network via the plurality of brokers;

determine, by the central processing unit in view of the comparing, that a broker of the plurality of brokers is connected to the first message consumer of the plurality of message consumers when the routing key corresponds to the IN, wherein the central processing unit is in data communication with the broker via the messaging network; and

route the message to the broker that is connected to the first message consumer that is associated with the IN.

12. The non-transitory computer-readable medium of claim 11, the central processing unit further to:

determine, in view of the comparing, whether there is a second message consumer of the plurality of message consumers that is directly connected to a computing system that can receive the message, wherein the computing system comprises that central processing unit; and

route the message to the second message consumer that was determined when the consumer can receive the message.

13. The non-transitory computer-readable medium of claim 11, wherein the message comprises content, and wherein the routing information comprises information that must match corresponding information in the content of the message, and wherein the information that must match is specified by the message consumer.

14. The non-transitory computer-readable medium of claim 11, wherein when storing routing information for each message consumer, the central processing unit is to:

update the routing information for a message consumer when the message consumer changes a connection status with the messaging network.