System and method for message processing and routing

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.

1. A computer system implemented method for expanding the messaging processing capability of a computerized message routing system comprising a message handler that performs routing of messages from a publisher to endpoint subscribers, pre-routing transformation of the messages prior to routing of the messages to the endpoint subscribers and post-routing transformation of the messages after routing of the messages to the endpoint subscribers, the method comprising:
 migrating via a computer system endpoint message transformation procedures, for transforming messages into a format previously unrecognized by the message handler, from being performed by a new group of endpoint subscribers to being performed by the message handler as post-routing message transformation procedures; 
 transforming by the message handler, using the migrated post-routing message transformation procedures, messages into the format previously unrecognized by the message handler; and 
 delivering the transformed messages to the new group of endpoint subscribers in the format previously unrecognized by the message handler. 
 
     
     
       2. The method of  claim 1 , wherein the endpoint message transformation procedures are migrated using a plug-in. 
     
     
       3. The method of  claim 1 , wherein the endpoint message transformation procedures are performed based on a publishing topic name. 
     
     
       4. The method of  claim 1 , wherein the message handler consumes messages via an IBM MQ messaging platform. 
     
     
       5. The method of  claim 1 , wherein the message handler consumes messages via a TIBCO ETX messaging platform. 
     
     
       6. The method of  claim 1 , wherein the message handler publishes messages via an IBM MQ messaging platform. 
     
     
       7. The method of  claim 1 , wherein the message handler publishes messages via a TIBCO ETX messaging platform. 
     
     
       8. The method of  claim 1 , wherein the new group of endpoint subscribers can consume messages only in the format previously unrecognized by the message handler. 
     
     
       9. An apparatus for expanding the messaging processing capability of a computerized message routing system comprising a message handler that performs routing of messages from a publisher to endpoint subscribers, pre-routing transformation of the messages prior to routing of the messages to the endpoint subscribers and post-routing transformation of the messages after routing of the messages to the endpoint subscribers, the apparatus 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:
 migrate endpoint message transformation procedures, for transforming messages into a format previously unrecognized by the message handler, from being performed by a new group of endpoint subscribers to being performed by the message handler as post-routing message transformation procedures; 
 transform by the message handler, using the migrated post-routing message transformation procedures, messages into the format previously unrecognized by the message handler; and 
 instructions to deliver the transformed messages to the new group of endpoint subscribers in the format previously unrecognized by the message handler. 
 
 
     
     
       10. The apparatus of  claim 9 , wherein the endpoint message transformation procedures are migrated using a plug-in. 
     
     
       11. The apparatus of  claim 9 , wherein the endpoint message transformation procedures are performed based on a publishing topic name. 
     
     
       12. The apparatus of  claim 9 , wherein the message handler consumes messages via an IBM MQ messaging platform. 
     
     
       13. The apparatus of  claim 9 , wherein the message handler consumes messages via a TIBCO ETX messaging platform. 
     
     
       14. The apparatus of  claim 9 , wherein the message handler publishes messages via an IBM MQ messaging platform. 
     
     
       15. The apparatus of  claim 9 , wherein the message handler publishes messages via a TIBCO ETX messaging platform. 
     
     
       16. The apparatus of  claim 9 , wherein the new group of endpoint subscribers can consume messages only in the format previously unrecognized by the message handler. 
     
     
       17. A processor-readable physical medium for expanding the messaging processing capability of a computerized message routing system comprising a message handler that performs routing of messages from a publisher to endpoint subscribers, pre-routing transformation of the messages prior to routing of the messages to the endpoint subscribers and post-routing transformation of the messages after routing of the messages to the endpoint subscribers, the medium storing processor-issuable-and-generated instructions to:
 migrate endpoint message transformation procedures, for transforming messages into a format previously unrecognized by the message handler, from being performed by a new group of endpoint subscribers to being performed by the message handler as post-routing message transformation procedures; 
 transform by the message handler, using the migrated post-routing message transformation procedures, messages into the format previously unrecognized by the message handler; and 
 instructions to deliver the transformed messages to the new group of endpoint subscribers in the format previously unrecognized by the message handler. 
 
     
     
       18. The processor-readable physical medium of  claim 17 , wherein the endpoint message transformation procedures are migrated using a plug-in. 
     
     
       19. The processor-readable physical medium of  claim 17 , wherein the endpoint message transformation procedures are performed based on a publishing topic name. 
     
     
       20. The processor-readable physical medium of  claim 17 , wherein the new group of endpoint subscribers can consume messages only in the format previously unrecognized by the message handler.