Rules engine for a persistent message store
First Claim
Patent Images
1. A method, comprising:
- storing a plurality of messages in a persistent message store, wherein the plurality of messages are copies of original messages transmitted from message producers to message consumers through an enterprise service bus in a distributed computing system, the plurality of messages being stored with keys that are determined from at least one of message headers, message contexts or message bodies;
storing a pre-generated message search rule that comprises a set of search criteria for finding messages with specific attributes that have been transmitted through the enterprise service bus;
receiving, by a processing device executing a rules engine, a command from a remote requestor to search the plurality of messages in the persistent message store for at least one message of the plurality of messages having the specific attributes, the command including a search rule identifier associated with the pre-generated message search rule; and
processing, by the processing device, the pre-generated message search rule based on the search rule identifier to search for the at least one message using the keys associated with the plurality of messages.
1 Assignment
0 Petitions
Accused Products
Abstract
A method and apparatus for using a persistent message store in a distributed computing system. A message is stored in a persistent message store, wherein the message is a copy of an original message transmitted from a message producer to a message consumer in a distributed computing system. A command is received from a requestor to search the persistent message store for a stored message, the command indicating a search rule. The search rule is processed by a rules engine of the persistent message store to search for the stored message.
31 Citations
19 Claims
-
1. A method, comprising:
-
storing a plurality of messages in a persistent message store, wherein the plurality of messages are copies of original messages transmitted from message producers to message consumers through an enterprise service bus in a distributed computing system, the plurality of messages being stored with keys that are determined from at least one of message headers, message contexts or message bodies; storing a pre-generated message search rule that comprises a set of search criteria for finding messages with specific attributes that have been transmitted through the enterprise service bus; receiving, by a processing device executing a rules engine, a command from a remote requestor to search the plurality of messages in the persistent message store for at least one message of the plurality of messages having the specific attributes, the command including a search rule identifier associated with the pre-generated message search rule; and processing, by the processing device, the pre-generated message search rule based on the search rule identifier to search for the at least one message using the keys associated with the plurality of messages. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A non-transitory machine-accessible storage medium including instructions that, when executed by a processing device, cause the processing device to perform operations comprising:
-
storing a plurality of messages in a persistent message store, wherein the plurality of messages are copies of original messages transmitted from message producers to message consumers through an enterprise service bus in a distributed computing system, the plurality of messages being stored with keys that are determined from at least one of message headers, message contexts or message bodies; storing a pre-generated message search rule that comprises a set of search criteria for finding messages with specific attributes that have been transmitted through the enterprise service bus; receiving, by the processing device, a command from a remote requestor to search the plurality of messages in the persistent message store for at least one message of the plurality of messages having the specific attributes, the command including a search rule identifier associated with the pre-generated message search rule; and processing, by the processing device, the pre-generated message search rule based on the search rule identifier to search for the at least one message using the keys associated with the plurality of messages. - View Dependent Claims (9, 10, 11, 12, 13)
-
-
14. An apparatus, comprising:
-
a first computing device comprising a router, networked to one or more message producers and one or more message consumers, to intercept a plurality of messages generated by the one or more message producers and to generate copies of the plurality of messages, wherein the router is a component of an enterprise service bus; a persistent message store, coupled with the first computing device, to store the copies of the plurality of messages, the copies of the plurality of messages being stored with keys that are determined from at least one of message headers, message contexts or message bodies, and to receive a command from a remote requestor to search for messages with specific attributes that have been transmitted through the enterprise service bus, the command including a search rule identifier associated with a pre-generated message search rule that comprises a set of criteria for finding messages with the specific attributes, and at least one of the first computing device or a second computing device coupled with the persistent message store comprising a rules engine to search the plurality of messages in the persistent message store for at least one message of the plurality of messages having the specific attributes using the pre-generated message search rule associated with the search rule identifier and further using the keys associated with the plurality of messages. - View Dependent Claims (15, 16, 17, 18, 19)
-
Specification