Uses of Interface
org.apache.camel.processor.aggregate.AggregationStrategy

Packages that use AggregationStrategy

org.apache.camel.model	The JAXB POJOs for the XML Configuration of the routing rules.
org.apache.camel.processor	A collection of Processor implementations which are used to implement the Enterprise Integration Patterns
org.apache.camel.processor.aggregate	Helper classes for the Aggregator pattern.
org.apache.camel.util.toolbox

Uses of AggregationStrategy in org.apache.camel.model

Methods in org.apache.camel.model that return AggregationStrategy

AggregationStrategy	PollEnrichDefinition.getAggregationStrategy()
AggregationStrategy	MulticastDefinition.getAggregationStrategy()
AggregationStrategy	SplitDefinition.getAggregationStrategy()
AggregationStrategy	RecipientListDefinition.getAggregationStrategy()
AggregationStrategy	AggregateDefinition.getAggregationStrategy()
AggregationStrategy	EnrichDefinition.getAggregationStrategy()

Methods in org.apache.camel.model with parameters of type AggregationStrategy

ExpressionClause<AggregateDefinition>	ProcessorDefinition.aggregate(AggregationStrategy aggregationStrategy) Aggregator EIP: Creates an aggregator allowing you to combine a number of messages together into a single message.
AggregateDefinition	ProcessorDefinition.aggregate(Expression correlationExpression, AggregationStrategy aggregationStrategy) Aggregator EIP: Creates an aggregator allowing you to combine a number of messages together into a single message.
MulticastDefinition	MulticastDefinition.aggregationStrategy(AggregationStrategy aggregationStrategy) Set the multicasting aggregationStrategy
SplitDefinition	SplitDefinition.aggregationStrategy(AggregationStrategy aggregationStrategy) Set the aggregationStrategy
RecipientListDefinition<Type>	RecipientListDefinition.aggregationStrategy(AggregationStrategy aggregationStrategy) Set the aggregationStrategy
AggregateDefinition	AggregateDefinition.aggregationStrategy(AggregationStrategy aggregationStrategy) Sets the aggregate strategy to use
Type	ProcessorDefinition.enrich(String resourceUri, AggregationStrategy aggregationStrategy) The Content Enricher EIP enriches an exchange with additional data obtained from a resourceUri.
MulticastDefinition	ProcessorDefinition.multicast(AggregationStrategy aggregationStrategy) Multicast EIP: Multicasts messages to all its child outputs; so that each processor and destination gets a copy of the original message to avoid the processors interfering with each other.
MulticastDefinition	ProcessorDefinition.multicast(AggregationStrategy aggregationStrategy, boolean parallelProcessing) Multicast EIP: Multicasts messages to all its child outputs; so that each processor and destination gets a copy of the original message to avoid the processors interfering with each other.
Type	ProcessorDefinition.pollEnrich(String resourceUri, AggregationStrategy aggregationStrategy) The Content Enricher EIP enriches an exchange with additional data obtained from a resourceUri using a PollingConsumer to poll the endpoint.
Type	ProcessorDefinition.pollEnrich(String resourceUri, long timeout, AggregationStrategy aggregationStrategy) The Content Enricher EIP enriches an exchange with additional data obtained from a resourceUri using a PollingConsumer to poll the endpoint.
void	PollEnrichDefinition.setAggregationStrategy(AggregationStrategy aggregationStrategy)
MulticastDefinition	MulticastDefinition.setAggregationStrategy(AggregationStrategy aggregationStrategy)
void	SplitDefinition.setAggregationStrategy(AggregationStrategy aggregationStrategy)
void	RecipientListDefinition.setAggregationStrategy(AggregationStrategy aggregationStrategy)
void	AggregateDefinition.setAggregationStrategy(AggregationStrategy aggregationStrategy)
void	EnrichDefinition.setAggregationStrategy(AggregationStrategy aggregationStrategy)
SplitDefinition	ProcessorDefinition.split(Expression expression, AggregationStrategy aggregationStrategy) Splitter EIP: Creates a splitter allowing you split a message into a number of pieces and process them individually.

Constructors in org.apache.camel.model with parameters of type AggregationStrategy

AggregateDefinition(Expression correlationExpression, AggregationStrategy aggregationStrategy)

EnrichDefinition(AggregationStrategy aggregationStrategy, String resourceUri)

PollEnrichDefinition(AggregationStrategy aggregationStrategy, String resourceUri, long timeout)

Uses of AggregationStrategy in org.apache.camel.processor

Methods in org.apache.camel.processor that return AggregationStrategy

AggregationStrategy	RecipientList.getAggregationStrategy()
AggregationStrategy	MulticastProcessor.getAggregationStrategy() Use MulticastProcessor.getAggregationStrategy(org.apache.camel.Exchange) instead.
protected AggregationStrategy	MulticastProcessor.getAggregationStrategy(Exchange exchange)

Methods in org.apache.camel.processor with parameters of type AggregationStrategy

protected void	MulticastProcessor.doAggregate(AggregationStrategy strategy, AtomicExchange result, Exchange exchange) Aggregate the Exchange with the current result
void	Enricher.setAggregationStrategy(AggregationStrategy aggregationStrategy) Sets the aggregation strategy for this enricher.
void	RecipientList.setAggregationStrategy(AggregationStrategy aggregationStrategy)
void	PollEnricher.setAggregationStrategy(AggregationStrategy aggregationStrategy) Sets the aggregation strategy for this poll enricher.
protected void	MulticastProcessor.setAggregationStrategyOnExchange(Exchange exchange, AggregationStrategy aggregationStrategy) Sets the given AggregationStrategy on the Exchange.

Constructors in org.apache.camel.processor with parameters of type AggregationStrategy

Enricher(AggregationStrategy aggregationStrategy, Producer producer)
Creates a new Enricher.

MulticastProcessor(CamelContext camelContext, Collection<Processor> processors, AggregationStrategy aggregationStrategy)

MulticastProcessor(CamelContext camelContext, Collection<Processor> processors, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean shutdownExecutorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean shareUnitOfWork)

PollEnricher(AggregationStrategy aggregationStrategy, PollingConsumer consumer, long timeout)
Creates a new PollEnricher.

RecipientListProcessor(CamelContext camelContext, ProducerCache producerCache, Iterator<Object> iter, AggregationStrategy aggregationStrategy)

RecipientListProcessor(CamelContext camelContext, ProducerCache producerCache, Iterator<Object> iter, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean shutdownExecutorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean shareUnitOfWork)

Splitter(CamelContext camelContext, Expression expression, Processor destination, AggregationStrategy aggregationStrategy)

Splitter(CamelContext camelContext, Expression expression, Processor destination, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean shutdownExecutorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean useSubUnitOfWork)

Uses of AggregationStrategy in org.apache.camel.processor.aggregate

Subinterfaces of AggregationStrategy in org.apache.camel.processor.aggregate

interface	CompletionAwareAggregationStrategy A specialized AggregationStrategy which has callback when the aggregated Exchange is completed.
interface	OptimisticLockingAwareAggregationStrategy A specialized AggregationStrategy which gets a callback when the aggregated Exchange fails to add in the OptimisticLockingAggregationRepository because of an OptimisticLockingAggregationRepository.OptimisticLockingException.
interface	TimeoutAwareAggregationStrategy A specialized AggregationStrategy which can handle timeouts as well.

Classes in org.apache.camel.processor.aggregate that implement AggregationStrategy

class	AbstractListAggregationStrategy<V> Aggregate all exchanges into a List of values defined by the AbstractListAggregationStrategy.getValue(Exchange) call.
class	AggregationStrategyBeanAdapter An AggregationStrategy that adapts to a POJO.
class	GroupedExchangeAggregationStrategy Aggregate all exchanges into a single combined Exchange holding all the aggregated exchanges in a List as the message body.
class	UseLatestAggregationStrategy An AggregationStrategy which just uses the latest exchange which is useful for status messages where old status messages have no real value.
class	UseOriginalAggregationStrategy An AggregationStrategy which just uses the original exchange which can be needed when you want to preserve the original Exchange.

Methods in org.apache.camel.processor.aggregate that return AggregationStrategy

AggregationStrategy

AggregateProcessor.getAggregationStrategy()

Methods in org.apache.camel.processor.aggregate with parameters of type AggregationStrategy

void	AggregateProcessor.setAggregationStrategy(AggregationStrategy aggregationStrategy)

Constructors in org.apache.camel.processor.aggregate with parameters of type AggregationStrategy

AggregateProcessor(CamelContext camelContext, Processor processor, Expression correlationExpression, AggregationStrategy aggregationStrategy, ExecutorService executorService, boolean shutdownExecutorService)

Uses of AggregationStrategy in org.apache.camel.util.toolbox

Classes in org.apache.camel.util.toolbox that implement AggregationStrategy

class

FlexibleAggregationStrategy<E> The Flexible Aggregation Strategy is a highly customizable, fluently configurable aggregation strategy.

Methods in org.apache.camel.util.toolbox that return AggregationStrategy

static AggregationStrategy	AggregationStrategies.bean(Class<?> type) Creates a AggregationStrategyBeanAdapter for using a POJO as the aggregation strategy.
static AggregationStrategy	AggregationStrategies.bean(Class<?> type, String methodName) Creates a AggregationStrategyBeanAdapter for using a POJO as the aggregation strategy.
static AggregationStrategy	AggregationStrategies.bean(Object bean) Creates a AggregationStrategyBeanAdapter for using a POJO as the aggregation strategy.
static AggregationStrategy	AggregationStrategies.bean(Object bean, String methodName) Creates a AggregationStrategyBeanAdapter for using a POJO as the aggregation strategy.
static AggregationStrategy	AggregationStrategies.beanAllowNull(Class<?> type, String methodName) Creates a AggregationStrategyBeanAdapter for using a POJO as the aggregation strategy.
static AggregationStrategy	AggregationStrategies.beanAllowNull(Object bean, String methodName) Creates a AggregationStrategyBeanAdapter for using a POJO as the aggregation strategy.
static AggregationStrategy	AggregationStrategies.groupedExchange() Creates a GroupedExchangeAggregationStrategy aggregation strategy.
static AggregationStrategy	AggregationStrategies.useLatest() Use the latest incoming exchange.
static AggregationStrategy	AggregationStrategies.useOriginal() Use the original exchange.