Using content based routing to scale cast iron like appliances

• US 9,882,845 B2
• Filed: 05/27/2016
• Issued: 01/30/2018
• Est. Priority Date: 12/14/2012
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Cuomo, Gennaro A., Joseph, Dinakaran, Moore, Victor S., Vaish, Rishi
• Primary Examiner(s): SALL, EL HADJI MALICK
• Application Number:
  US15/166,445
• Publication Number:
  US 20160277337A1
• Time in Patent Office: 613 Days
• Field of Search: 709206, 709203, 709223, 709239, 709200
• CPC Class Codes: G06F 40/174 Form filling; Merging
• CPC Class Codes: G06F 40/186 Templates
• CPC Class Codes: G06F 40/205 Parsing
• CPC Class Codes: H04L 45/14 Routing performance; Theoretical aspects
• CPC Class Codes: H04L 51/04 Real-time or near real-time messaging, e.g. instant messaging [IM]
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 51/52 for supporting social networking services

Abstract

Routing messages to message queues may be provided. In one embodiment of the present disclosure, a message may be routed to a message queue based on topic of the message, content of the message, application for which the message was intended, and/or a set of rules such as a rule based on queue length and queue balancing. A template integration process may subscribe to one or more topic queues, from which input parameters are obtained for invoking a service request from an application.

Claims

1. A method for context based routing of messages, comprising:

receiving a message for routing by a message switch implemented in a hardware processor;

parsing the message to identify a topic and a data payload of the message;

identifying a topic queue to which to route the message based on the topic and the data payload;

routing the message to the topic queue;

executing automatically a template integration process subscribing to the topic queue, in response to the message being routed to the topic queue, the template integration process comprising a configurable and executable template that provides a service, the template integration process invoking an application service for providing the service, with a request comprising data extracted from the message for the application service to handle the request, the template integration process receiving a result of handling of the service from the application service.

2. The method of claim 1, wherein the message is the topic queue identified based further on one or more criteria.

3. The method of claim 2, wherein the one or more criteria comprises queue length and a queue balancing for spreading out a number of the messages among a plurality of topic queues.

4. The method of claim 1, the one or more criteria utilize analytics and temporal based rules for routing messages.

5. The method of claim 1, further comprising:

creating a new message for further routing based on the result;

routing the new message to a destination point, wherein the destination point comprises another topic queue.

6. The method of claim 5, wherein said creating and said routing is performed based on the template integration process that is preconfigured to create the new message and to route the new message to said another topic queue.

7. The method of claim 1, wherein the template integration process is preconfigured to invoke the application service in response to the message being routed to the topic queue.

8. A computer readable storage medium storing a program of instructions executable by a machine to perform a method of context based routing of messages, comprising:

receiving a message for routing by a message switch;

parsing the message to identify a topic and a data payload of the message;

identifying a topic queue to which to route the message based on the topic and the data payload;

routing the message to the topic queue;

executing automatically a template integration process subscribing to the topic queue, in response to the message being routed to the topic queue, the template integration process comprising a configurable and executable template that provides a service, the template integration process invoking an application service for providing the service, with a request comprising data extracted from the message for the application service to handle the request, the template integration process receiving a result of handling of the service from the application service.

9. The computer readable storage medium of claim 8, wherein the message is the topic queue identified based further on one or more criteria.

10. The computer readable storage medium of claim 9, wherein the one or more criteria comprises queue length and a queue balancing for spreading out a number of the messages among a plurality of topic queues.

11. The computer readable storage medium of claim 8, the one or more criteria utilize analytics and temporal based rules for routing messages.

12. The computer readable storage medium of claim 8, further comprising:

creating a new message for further routing based on the result;

routing the new message to a destination point, wherein the destination point comprises another topic queue.

13. The computer readable storage medium of claim 12, wherein said creating and said routing is performed based on the template integration process that is preconfigured to create the new message and to route the new message to said another topic queue.

14. The computer readable storage medium of claim 8, wherein the template integration process is preconfigured to invoke the application service in response to the message being routed to the topic queue.

15. A system for context based routing of messages, comprising:

a message switch comprising at least a hardware processor and a plurality of topic queues, the message switch operable to receive a message, parse the message to identify a topic and a data payload of the message, identify a topic queue among the plurality of topic queues, to which to route the message based on the topic and the data payload, and route the message to the topic queue; and

a template integration process that subscribes to the topic queue, the template integration process executed automatically in response to the message being routed to the topic queue, the template integration process comprising a configurable and executable template that provides a service, the template integration process invoking an application service for providing the service, with a request comprising data extracted from the message for the application service to handle the request, the template integration process receiving a result of handling of the service from the application service.

16. The system of claim 15, wherein the hardware processor comprises a field programmable gate array.

17. The system of claim 15, wherein the template integration process is further operable to create a new message for further routing based on the result, and route the new message to a destination point, wherein the destination point comprises another topic queue.

18. The system of claim 17, wherein the template integration process is preconfigured to create the new message and to route the new message to said another topic queue.

19. The system of claim 18, wherein said another topic queue is subscribed to by another template integration process that is preconfigured to invoke another service request from another application based on the new message placed in said another topic queue.

20. The system of claim 15, wherein the template integration process is preconfigured to invoke the application service in response to the message being routed to the topic queue.