System and method for message processing and routing

• US 7,895,359 B2
• Filed: 04/04/2008
• Issued: 02/22/2011
• Est. Priority Date: 05/01/2003
• Status: Active Grant

• Current Assignee: Goldman Sachs & Co. LLC (Goldman Sachs Group Incorporated)
• Original Assignee: Goldman Sachs & Company (Goldman Sachs Group Incorporated)
• Inventors: Reed, Carl J., Marzo, Michael R., Kanayama, Tomozumi, Krasheninnikov, Konstantin A., Beguin, Julien George
• Primary Examiner(s): Walsh, John B.
• Application Number:
  US12/080,708
• Publication Number:
  US 20080228884A1
• Time in Patent Office: 1,054 Days
• Field of Search: None
• US Class Current: 709/238
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• 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
• CPC Class Codes: H04L 69/329 in the application layer [OSI layer 7]

Abstract

A message routing system that allows applications at either end of the system to run as-is without modification. The system functions in a multithreaded environment and is capable of handling complex routing rules and message transformation. It is also capable of learning and executing new routing rules and message transformations in formats previously unrecognized by the system. The system enables precise and reliable logging of messages throughout processing and supports publication of enterprise-wide broadcast messages. The system further preferably employs cooperating inbound and outbound transport processes for consuming, routing, processing, safely storing and publishing messages in batches of logical units of work to ensure that the logical units of work are not lost in system transactions. The system also preferably utilizes a replay server for preserving and replaying messages that might otherwise fail to reach their intended destinations.

Claims

1. A computer system implemented method for operating a computerized message routing system, said method comprising:

consuming a message from a message bus of an inbound messaging node;

invoking, via a computer system, an introspection module based on an inbound subject on which the message has been published to the inbound node;

examining the contents of the message;

extracting a first routing key corresponding to a first routing rule from the message based on the contents of the message;

examining the first routing key;

identifying a routing tag based on the first routing key;

evaluating, via the computer system, the identified routing tag to determine an outbound subject to which the identified routing tag is bound;

publishing the message to the outbound subject using a message bus of an outbound messaging node; and

extracting a second routing key corresponding to a second routing rule from the message based on the contents of the message, wherein the identified routing tag is used to select the second routing rule;

dynamically loading the introspection module based on a source of the message, before invoking the introspection module;

caching a keymap table and an outbound routing table in local memory upon loading the introspection module;

identifying the routing tag using the keymap table; and

evaluating the routing tag to determine the outbound subject using the outbound routing table.

2. The method of claim 1, wherein the inbound subject is a general subject and the outbound subject is a specific subject.

3. The method of claim 1, wherein the message is consumed via an IBM MQ messaging platform.

4. The method of claim 1, wherein the message is consumed via a TIBCO ETX messaging platform.

5. The method of claim 1, wherein the message is published via an IBM MQ messaging platform.

6. The method of claim 1, wherein the message is published via a TIBCO ETX messaging platform.

7. The method of claim 1, wherein the message is formatted using Extensible Markup Language.

8. An apparatus for operating a computerized message routing system, comprising:

a memory;

a processor disposed in communication with said memory, and configured to issue a plurality of processing instructions stored in the memory, wherein the processor issues instructions to;

consume a message from a message bus of an inbound messaging node;

invoke an introspection module based on an inbound subject on which the message has been published to the inbound node;

examine the contents of the message;

extract a first routing key corresponding to a first routing rule from the message based on the contents of the message;

examine the first routing key;

identify a routing tag based on the first routing key;

evaluate the identified routing tag to determine an outbound subject to which the identified routing tag is bound;

publish the message to the outbound subject using a message bus of an outbound messaging node; and

extract a second routing key corresponding to a second routing rule from the message based on the contents of the message, wherein the identified routing tag is used to select the second routing rule;

dynamically load the introspection module based on a source of the message, before invoking the introspection module;

cache a keymap table and an outbound routing table in local memory upon loading the introspection module;

identify the routing tag using the keymap table; and

evaluate the routing tag to determine the outbound subject using the outbound routing table.

9. The apparatus of claim 8, wherein the inbound subject is a general subject and the outbound subject is a specific subject.

10. The apparatus of claim 8, wherein the message is consumed via an IBM MQ messaging platform.

11. The apparatus of claim 8, wherein the message is consumed via a TIBCO ETX messaging platform.

12. The apparatus of claim 8, wherein the message is published via an IBM MQ messaging platform.

13. The apparatus of claim 8, wherein the message is published via a TIBCO ETX messaging platform.

14. The apparatus of claim 8, wherein the message is formatted using Extensible Markup Language.

15. A processor-readable non-transitory physical medium for operating a computerized message routing system storing processor-issuable-and-generated instructions to:

consume a message from a message bus of an inbound messaging node;

invoke an introspection module based on an inbound subject on which the message has been published to the inbound node;

examine the contents of the message;

extract a first routing key corresponding to a first routing rule from the message based on the contents of the message;

examine the first routing key;

identify a routing tag based on the first routing key;

evaluate the identified routing tag to determine an outbound subject to which the identified routing tag is bound;

publish the message to the outbound subject using a message bus of an outbound messaging node; and

extract a second routing key corresponding to a second routing rule from the message based on the contents of the message, wherein the identified routing tag is used to select the second routing rule;

dynamically load the introspection module based on a source of the message, before invoking the introspection module;

cache a keymap table and on an outbound routing table in local memory upon loading the introspection module;

identify the routing tag using the keymap table; and

evaluate the routing tag to determine the outbound subject using the outbound routing table.