Uses of Class
org.apache.camel.model.AggregateDefinition

Packages that use AggregateDefinition

org.apache.camel.impl	Default implementation classes for Camel Core
org.apache.camel.model	The JAXB POJOs for the XML Configuration of the routing rules.

Uses of AggregateDefinition in org.apache.camel.impl

Constructors in org.apache.camel.impl with parameters of type AggregateDefinition

AggregateRouteNode(AggregateDefinition aggregateDefinition)

Uses of AggregateDefinition in org.apache.camel.model

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

AggregateDefinition	ProcessorDefinition.aggregate(Expression correlationExpression) 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.
AggregateDefinition	AggregateDefinition.aggregationRepository(AggregationRepository aggregationRepository) Sets the custom aggregate repository to use.
AggregateDefinition	AggregateDefinition.aggregationRepositoryRef(String aggregationRepositoryRef) Sets the custom aggregate repository to use Will by default use MemoryAggregationRepository
AggregateDefinition	AggregateDefinition.aggregationStrategy(AggregationStrategy aggregationStrategy) Sets the aggregate strategy to use
AggregateDefinition	AggregateDefinition.aggregationStrategyMethodAllowNull() Sets allowing null when using a POJO as AggregationStrategy.
AggregateDefinition	AggregateDefinition.aggregationStrategyMethodName(String methodName) Sets the method name to use when using a POJO as AggregationStrategy.
AggregateDefinition	AggregateDefinition.aggregationStrategyRef(String aggregationStrategyRef) Sets the aggregate strategy to use
AggregateDefinition	AggregateDefinition.closeCorrelationKeyOnCompletion(int capacity) Closes a correlation key when its complete.
AggregateDefinition	AggregateDefinition.completionFromBatchConsumer() Enables the batch completion mode where we aggregate from a BatchConsumer and aggregate the total number of exchanges the BatchConsumer has reported as total by checking the exchange property Exchange.BATCH_COMPLETE when its complete.
AggregateDefinition	AggregateDefinition.completionInterval(long completionInterval) Sets the completion interval, which would cause the aggregate to consider the group as complete and send out the aggregated exchange.
AggregateDefinition	AggregateDefinition.completionPredicate(Predicate predicate) Sets the predicate used to determine if the aggregation is completed
AggregateDefinition	AggregateDefinition.completionSize(Expression completionSize) Sets the completion size, which is the number of aggregated exchanges which would cause the aggregate to consider the group as complete and send out the aggregated exchange.
AggregateDefinition	AggregateDefinition.completionSize(int completionSize) Sets the completion size, which is the number of aggregated exchanges which would cause the aggregate to consider the group as complete and send out the aggregated exchange.
AggregateDefinition	AggregateDefinition.completionTimeout(Expression completionTimeout) Sets the completion timeout, which would cause the aggregate to consider the group as complete and send out the aggregated exchange.
AggregateDefinition	AggregateDefinition.completionTimeout(long completionTimeout) Sets the completion timeout, which would cause the aggregate to consider the group as complete and send out the aggregated exchange.
AggregateDefinition	AggregateDefinition.discardOnCompletionTimeout() Discards the aggregated message on completion timeout.
AggregateDefinition	AggregateDefinition.eagerCheckCompletion() Use eager completion checking which means that the {{completionPredicate}} will use the incoming Exchange.
AggregateDefinition	AggregateDefinition.executorService(ExecutorService executorService)
AggregateDefinition	AggregateDefinition.executorServiceRef(String executorServiceRef)
AggregateDefinition	AggregateDefinition.forceCompletionOnStop() Sets the force completion on stop flag, which considers the current group as complete and sends out the aggregated exchange when the stop event is executed
AggregateDefinition	AggregateDefinition.groupExchanges() Enables grouped exchanges, so the aggregator will group all aggregated exchanges into a single combined Exchange holding all the aggregated exchanges in a List.
AggregateDefinition	AggregateDefinition.ignoreInvalidCorrelationKeys() If a correlation key cannot be successfully evaluated it will be ignored by logging a {{DEBUG}} and then just ignore the incoming Exchange.
AggregateDefinition	AggregateDefinition.optimisticLocking()
AggregateDefinition	AggregateDefinition.optimisticLockRetryPolicy(OptimisticLockRetryPolicy policy)
AggregateDefinition	AggregateDefinition.parallelProcessing() Sending the aggregated output in parallel
AggregateDefinition	AggregateDefinition.timeoutCheckerExecutorService(ScheduledExecutorService executorService)
AggregateDefinition	AggregateDefinition.timeoutCheckerExecutorServiceRef(String executorServiceRef)

Methods in org.apache.camel.model that return types with arguments of type AggregateDefinition

ExpressionClause<AggregateDefinition>	ProcessorDefinition.aggregate() Aggregator EIP: Creates an aggregator allowing you to combine a number of messages together into a single message.
ExpressionClause<AggregateDefinition>	ProcessorDefinition.aggregate(AggregationStrategy aggregationStrategy) Aggregator EIP: Creates an aggregator allowing you to combine a number of messages together into a single message.