public class GroupedMessageAggregationStrategy extends AbstractListAggregationStrategy<Message>
Message into a single combined Exchange holding all the
aggregated messages in a List of Message as the message body.
This aggregation strategy can used in combination with Splitter to batch messages| Constructor and Description |
|---|
GroupedMessageAggregationStrategy() |
| Modifier and Type | Method and Description |
|---|---|
Exchange |
aggregate(Exchange oldExchange,
Exchange newExchange)
This method will aggregate the old and new exchange and return the result.
|
Message |
getValue(Exchange exchange)
This method is implemented by the sub-class and is called to retrieve
an instance of the value that will be aggregated and forwarded to the
receiving end point.
|
isStoreAsBodyOnCompletion, onCompletionpublic GroupedMessageAggregationStrategy()
public Exchange aggregate(Exchange oldExchange, Exchange newExchange)
AbstractListAggregationStrategyaggregate in interface AggregationStrategyaggregate in class AbstractListAggregationStrategy<Message>oldExchange - The oldest exchange, can be nullnewExchange - The newest exchange, can be nullpublic Message getValue(Exchange exchange)
AbstractListAggregationStrategyList.getValue in class AbstractListAggregationStrategy<Message>exchange - The exchange that is used to retrieve the value fromApache Camel