Policy based message aggregation framework
First Claim
1. A computerized method of aggregating messages comprising:
- receiving a plurality of messages from at least one application;
executing a batch configuration policy on the received messages;
aggregating the received messages in a batch as a function of the batch configuration policy;
assembling the batch into a single stream message output.
2 Assignments
0 Petitions
Accused Products
Abstract
Messages generated by an originating application are aggregated into batches based on a configuration policy. The configuration policy contains business logic used to aggregate messages into a batch. Once a batch is complete, it is formatted into a single stream output and sent to a destination application designed to receive the messages. Messages may also be aggregated into batches that are controlled by the originating application. The messages include an indicator set by the originating application to signal when a batch is complete. Once the batch is complete, it is formatted into a single stream output and sent to a destination application designed to receive the messages.
-
Citations
20 Claims
-
1. A computerized method of aggregating messages comprising:
-
receiving a plurality of messages from at least one application;
executing a batch configuration policy on the received messages;
aggregating the received messages in a batch as a function of the batch configuration policy;
assembling the batch into a single stream message output. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A computerized method of aggregating messages comprising:
-
receiving a plurality of messages from at least one application, said messages including a batch identifier and a batch end indicator;
aggregating the received messages in a batch as a function of the batch identifier;
completing the aggregating as a function of the batch end indicator;
assembling the batch into a single stream message output. - View Dependent Claims (13, 14, 15, 16, 17, 18)
-
-
19. A system for aggregating messages for an application, said messages being addressed to a send port, said system comprising one or more computer-executable components comprising:
-
a message engine component for receiving messages from the application;
a batch configuration policy, said batch configuration policy containing business logic to batch the messages for the application;
a batcher component for aggregating messages into a batch as a function of the batch configuration policy, said batcher component being associated with the send port, said batcher component receiving messages addressed to the send port from the message engine; and
wherein the message engine component creates a new instance of the batcher associated with the send port if the batcher component associated with the send port does not exist. - View Dependent Claims (20)
-
Specification