Package org.openehealth.ipf.platform.camel.core.adapter

Class AggregatorAdapter

java.lang.Object

org.openehealth.ipf.platform.camel.core.adapter.AdapterSupport

org.openehealth.ipf.platform.camel.core.adapter.AggregatorAdapter

All Implemented Interfaces:

AggregationStrategy, Adapter

public class AggregatorAdapter
extends AdapterSupport
implements AggregationStrategy

Adapts an Aggregator.

Author:

Martin Krasser

Constructor Summary

Constructors

Constructor	Description
AggregatorAdapter(Aggregator aggregator)	Creates a new AggregatorAdapter and sets the delegate Aggregator.

Method Summary

Modifier and Type	Method	Description
Exchange	aggregate(Exchange oldExchange, Exchange newExchange)	Applies expressions to oldExchange and newExchange and delegates further processing to doAggregate(Exchange, Object, Object, Object...)
AggregatorAdapter	aggregationInput(Closure aggregationInputExpressionLogic)	Sets an expression Closure for obtaining data to be obtained from an additional (new) Exchange.
AggregatorAdapter	aggregationInput(Expression aggregationInputExpression)	Sets an Expression for obtaining data to be obtained from an additional (new) Exchange.
protected void	doAggregate(Exchange oldExchange, Object oldInputData, Object newInputData, Object... inputParams)	Aggregates oldInputData and newInputData.

Methods inherited from class org.openehealth.ipf.platform.camel.core.adapter.AdapterSupport

adaptInput, adaptParams, input, input, params, params, staticParams

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.camel.AggregationStrategy

aggregate, canPreComplete, onCompletion, onCompletion, onOptimisticLockFailure, preComplete, timeout

Constructor Details

AggregatorAdapter

public AggregatorAdapter(Aggregator aggregator)

Creates a new AggregatorAdapter and sets the delegate Aggregator.

Parameters:

aggregator - an aggregator.

Method Details

aggregationInput

public AggregatorAdapter aggregationInput(Expression aggregationInputExpression)

Sets an Expression for obtaining data to be obtained from an additional (new) Exchange. The default expression obtains the body from the input message.

Parameters:

aggregationInputExpression - expression for obtaining aggregation input data.

Returns:

this object.

See Also:

• aggregate(Exchange, Exchange)

aggregationInput

public AggregatorAdapter aggregationInput(Closure aggregationInputExpressionLogic)

Sets an expression Closure for obtaining data to be obtained from an additional (new) Exchange. The default expression obtains the body from the input message.

Parameters:

aggregationInputExpressionLogic - expression for obtaining aggregation input data.

Returns:

this object.

See Also:

• aggregate(Exchange, Exchange)

aggregate

public Exchange aggregate(Exchange oldExchange,
 Exchange newExchange)

Applies expressions to oldExchange and newExchange and delegates further processing to doAggregate(Exchange, Object, Object, Object...)

Specified by:

aggregate in interface AggregationStrategy

See Also:

• aggregationInput(Expression)
• AdapterSupport.input(Expression)
• AdapterSupport.params(Expression)

doAggregate

protected void doAggregate(Exchange oldExchange,
 Object oldInputData,
 Object newInputData,
 Object... inputParams)

Aggregates oldInputData and newInputData. The aggregation result is written to body of the message returned by Exchanges.resultMessage(Exchange).

Parameters:

oldExchange - original message exchange to write results to.

oldInputData - original input data

newInputData - additional input data

inputParams - input parameters