System and method for message processing and routing
First Claim
1. A method for operating a computerized message routing system, said method comprising the steps of:
- (a) consuming a message from a message bus of an inbound messaging node;
(b) invoking an introspection module based on a subject on which the message has been published to the inbound node;
(c) examining the contents of the message;
(d) extracting at least one routing key from the message based on the contents of the message;
(e) examining the at least one routing key;
(f) identifying a routing tag based on the at least one routing key;
(g) evaluating the routing tag to determine whether the routing tag is bound to one or both of an outbound subject and a routing rule; and
, either(h) if the routing tag is bound to an outbound subject, then publishing the message to a message bus of an outbound messaging node, or(i) if the routing tag is bound to a routing rule or a routing rule and an outbound subject, then extracting at least one routing key based on the routing rule and repeating steps (g), (h) and (i) until the message is published to a message bus of an outbound messaging node.
2 Assignments
0 Petitions
Accused Products
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.
-
Citations
1 Claim
-
1. A method for operating a computerized message routing system, said method comprising the steps of:
-
(a) consuming a message from a message bus of an inbound messaging node; (b) invoking an introspection module based on a subject on which the message has been published to the inbound node; (c) examining the contents of the message; (d) extracting at least one routing key from the message based on the contents of the message; (e) examining the at least one routing key; (f) identifying a routing tag based on the at least one routing key; (g) evaluating the routing tag to determine whether the routing tag is bound to one or both of an outbound subject and a routing rule; and
, either(h) if the routing tag is bound to an outbound subject, then publishing the message to a message bus of an outbound messaging node, or (i) if the routing tag is bound to a routing rule or a routing rule and an outbound subject, then extracting at least one routing key based on the routing rule and repeating steps (g), (h) and (i) until the message is published to a message bus of an outbound messaging node.
-
Specification