|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AggregatorType | |
---|---|
org.apache.camel.model | The JAXB POJOs for the XML Configuration of the routing rules. |
Uses of AggregatorType in org.apache.camel.model |
---|
Methods in org.apache.camel.model that return AggregatorType | |
---|---|
AggregatorType |
AggregatorType.aggregationCollection(AggregationCollection aggregationCollection)
|
AggregatorType |
AggregatorType.aggregationStrategy(AggregationStrategy aggregationStrategy)
|
AggregatorType |
ProcessorType.aggregator(AggregationCollection aggregationCollection)
Creates an Aggregator pattern using a custom aggregation collection implementation. |
AggregatorType |
ProcessorType.aggregator(Expression correlationExpression)
Creates an Aggregator pattern where a batch of messages are processed (up to a maximum amount or until some timeout is reached) and messages for the same correlation key are combined together using some kind of AggregationStrategy
(by default the latest message is used) to compress many message exchanges
into a smaller number of exchanges. |
AggregatorType |
ProcessorType.aggregator(Expression correlationExpression,
AggregationStrategy aggregationStrategy)
Creates an Aggregator pattern where a batch of messages are processed (up to a maximum amount or until some timeout is reached) and messages for the same correlation key are combined together using some kind of AggregationStrategy
(by default the latest message is used) to compress many message exchanges
into a smaller number of exchanges. |
AggregatorType |
AggregatorType.batchSize(int batchSize)
|
AggregatorType |
AggregatorType.batchTimeout(long batchTimeout)
|
AggregatorType |
AggregatorType.completedPredicate(Predicate predicate)
Sets the predicate used to determine if the aggregation is completed |
AggregatorType |
AggregatorType.outBatchSize(int batchSize)
|
AggregatorType |
AggregatorType.strategyRef(String strategyRef)
|
Methods in org.apache.camel.model that return types with arguments of type AggregatorType | |
---|---|
ExpressionClause<AggregatorType> |
ProcessorType.aggregator()
Creates an Aggregator pattern where a batch of messages are processed (up to a maximum amount or until some timeout is reached) and messages for the same correlation key are combined together using some kind of AggregationStrategy
(by default the latest message is used) to compress many message exchanges
into a smaller number of exchanges. |
ExpressionClause<AggregatorType> |
ProcessorType.aggregator(AggregationStrategy aggregationStrategy)
Creates an Aggregator pattern where a batch of messages are processed (up to a maximum amount or until some timeout is reached) and messages for the same correlation key are combined together using some kind of AggregationStrategy
(by default the latest message is used) to compress many message exchanges
into a smaller number of exchanges. |
ExpressionClause<AggregatorType> |
AggregatorType.completedPredicate()
Sets the predicate used to determine if the aggregation is completed |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |