Package | Description |
---|---|
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.
|
Constructor and Description |
---|
AggregateRouteNode(AggregateDefinition aggregateDefinition) |
Modifier and Type | Method and Description |
---|---|
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)
If using parallelProcessing you can specify a custom thread pool to be used.
|
AggregateDefinition |
AggregateDefinition.executorServiceRef(String executorServiceRef)
If using parallelProcessing you can specify a custom thread pool to be used.
|
AggregateDefinition |
AggregateDefinition.forceCompletionOnStop()
Indicates to complete all current aggregated exchanges when the context is stopped
|
AggregateDefinition |
AggregateDefinition.groupExchanges()
Deprecated.
use
GroupedExchangeAggregationStrategy as aggregation strategy instead. |
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()
Turns on using optimistic locking, which requires the aggregationRepository being used,
is supporting this by implementing
OptimisticLockingAggregationRepository . |
AggregateDefinition |
AggregateDefinition.optimisticLockRetryPolicy(OptimisticLockRetryPolicy policy)
Allows to configure retry settings when using optimistic locking.
|
AggregateDefinition |
AggregateDefinition.parallelProcessing()
When aggregated are completed they are being send out of the aggregator.
|
AggregateDefinition |
AggregateDefinition.timeoutCheckerExecutorService(ScheduledExecutorService executorService)
If using either of the completionTimeout, completionTimeoutExpression, or completionInterval options a
background thread is created to check for the completion for every aggregator.
|
AggregateDefinition |
AggregateDefinition.timeoutCheckerExecutorServiceRef(String executorServiceRef)
If using either of the completionTimeout, completionTimeoutExpression, or completionInterval options a
background thread is created to check for the completion for every aggregator.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Apache Camel