System and method for message processing and routing

• US 8,250,162 B2
• Filed: 08/23/2011
• Issued: 08/21/2012
• 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, Beguin, Julien George, Krashneninnikov, Konstantin A.
• Primary Examiner(s): Walsh, John B.
• Application Number:
  US13/215,346
• Publication Number:
  US 20110307568A1
• Time in Patent Office: 364 Days
• Field of Search: None
• US Class Current: 709/206
• 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 system for expanding the messaging processing capability of a computerized message routing system, the 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;

provide a message handler with endpoint message transformation procedures performed by a group of endpoint subscribers that desire to receive messages in a format previously unrecognized by the message handler;

wherein the message handler performs routing of messages from a publisher to the endpoint subscribers;

wherein a pre-routing transformation of the messages is performed prior to routing the messages to the endpoint subscribers;

automatically perform via the message handler the endpoint message transformation procedures formerly performed by the group of endpoint subscribers as a post-routing message transformation; and

deliver messages to the group of endpoint subscribers in the format previously unrecognized by the message handler when all members of the group of endpoint subscribers have made their endpoint message transformation procedures known to the message handler.

2. The system of claim 1, wherein the endpoint message transformation procedures are performed based on a publishing topic name.

3. The system of claim 1, wherein the message handler consumes messages via an IBM MQ messaging platform.

4. The system of claim 1, wherein the message handler consumes messages via a TIBCO ETX messaging platform.

5. The system of claim 1, wherein the message handler publishes messages via an IBM MQ messaging platform 1.

6. The system of claim 1, wherein the message handler publishes messages via a TIBCO ETX messaging platform.

7. The system of claim 1, wherein the group of endpoint subscribers can consume messages only in the format previously unrecognized by the message handler.