public class GroupedExchangeAggregationStrategy extends AbstractListAggregationStrategy<Exchange>
List of Exchange as the message body.| Constructor and Description |
|---|
GroupedExchangeAggregationStrategy() |
| 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.
|
Exchange |
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.
|
void |
onCompletion(Exchange exchange)
The aggregated
Exchange has completed
Important: This method must not throw any exceptions. |
isStoreAsBodyOnCompletionpublic void onCompletion(Exchange exchange)
CompletionAwareAggregationStrategyExchange has completed
Important: This method must not throw any exceptions.onCompletion in interface CompletionAwareAggregationStrategyonCompletion in class AbstractListAggregationStrategy<Exchange>exchange - the current aggregated exchange, or the original Exchange if no aggregation
has been done before the completion occurredpublic Exchange aggregate(Exchange oldExchange, Exchange newExchange)
AbstractListAggregationStrategyaggregate in interface AggregationStrategyaggregate in class AbstractListAggregationStrategy<Exchange>oldExchange - The oldest exchange, can be nullnewExchange - The newest exchange, can be nullpublic Exchange getValue(Exchange exchange)
AbstractListAggregationStrategyList.getValue in class AbstractListAggregationStrategy<Exchange>exchange - The exchange that is used to retrieve the value fromApache Camel