public interface MessageAggregator
Modifier and Type | Interface and Description |
---|---|
static class |
MessageAggregator.AggregationConstants |
Modifier and Type | Method and Description |
---|---|
void |
aggregate(Message msg)
Aggregate the current message according to configuration of the aggregator instance.
|
void |
beginTimer(Message m)
Begin timer to process expired messages for aggregated responses to this message
|
void aggregate(Message msg)
msg
- the message to be aggregatedvoid beginTimer(Message m)
m
- the original parent message (See sample # 212)Copyright © 2010–2016 AdroitLogic. All rights reserved.