public class AggregatorAdapter extends AdapterSupport implements org.apache.camel.processor.aggregate.AggregationStrategy
Aggregator
.Constructor and Description |
---|
AggregatorAdapter(Aggregator aggregator)
Creates a new
AggregatorAdapter and sets the delegate
Aggregator . |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
aggregate(org.apache.camel.Exchange oldExchange,
org.apache.camel.Exchange newExchange)
Applies expressions to
oldExchange and
newExchange and delegates further processing to
doAggregate(Exchange, Object, Object, Object...) |
AggregatorAdapter |
aggregationInput(groovy.lang.Closure aggregationInputExpressionLogic)
Sets an expression
Closure for obtaining data to be obtained from
an additional (new) Exchange . |
AggregatorAdapter |
aggregationInput(org.apache.camel.Expression aggregationInputExpression)
Sets an
Expression for obtaining data to be obtained from an
additional (new) Exchange . |
protected void |
doAggregate(org.apache.camel.Exchange oldExchange,
Object oldInputData,
Object newInputData,
Object... inputParams)
Aggregates
oldInputData and newInputData . |
adaptInput, adaptParams, input, input, params, params, staticParams
public AggregatorAdapter(Aggregator aggregator)
AggregatorAdapter
and sets the delegate
Aggregator
.aggregator
- an aggregator.public AggregatorAdapter aggregationInput(org.apache.camel.Expression aggregationInputExpression)
Expression
for obtaining data to be obtained from an
additional (new) Exchange
. The default expression obtains the
body from the input message.aggregationInputExpression
- expression for obtaining aggregation input data.aggregate(Exchange, Exchange)
public AggregatorAdapter aggregationInput(groovy.lang.Closure aggregationInputExpressionLogic)
Closure
for obtaining data to be obtained from
an additional (new) Exchange
. The default expression obtains the
body from the input message.aggregationInputExpressionLogic
- expression for obtaining aggregation input data.aggregate(Exchange, Exchange)
public org.apache.camel.Exchange aggregate(org.apache.camel.Exchange oldExchange, org.apache.camel.Exchange newExchange)
oldExchange
and
newExchange
and delegates further processing to
doAggregate(Exchange, Object, Object, Object...)
aggregate
in interface org.apache.camel.processor.aggregate.AggregationStrategy
aggregationInput(Expression)
,
AdapterSupport.input(Expression)
,
AdapterSupport.params(Expression)
protected void doAggregate(org.apache.camel.Exchange oldExchange, Object oldInputData, Object newInputData, Object... inputParams)
oldInputData
and newInputData
.
The aggregation result is written to body of the message returned by
Exchanges.resultMessage(Exchange)
.oldExchange
- original message exchange to write results to.oldInputData
- original input datanewInputData
- additional input datainputParams
- input parametersCopyright © 2018 Open eHealth Foundation. All rights reserved.