|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AggregateDefinition | |
---|---|
org.apache.camel.model | The JAXB POJOs for the XML Configuration of the routing rules. |
Uses of AggregateDefinition in org.apache.camel.model |
---|
Methods in org.apache.camel.model that return AggregateDefinition | |
---|---|
AggregateDefinition |
ProcessorDefinition.aggregate(AggregationCollection aggregationCollection)
Aggregator EIP: Creates an aggregator allowing you to combine a number of messages together into a single message. |
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.aggregationCollection(AggregationCollection aggregationCollection)
Sets the aggregate collection to use |
AggregateDefinition |
AggregateDefinition.aggregationStrategy(AggregationStrategy aggregationStrategy)
Sets the aggregate strategy to use |
AggregateDefinition |
AggregateDefinition.batchSize(int batchSize)
Sets the in batch size for number of exchanges received |
AggregateDefinition |
AggregateDefinition.batchSizeFromConsumer()
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 setting the exchange property Exchange.BATCH_SIZE . |
AggregateDefinition |
AggregateDefinition.batchTimeout(long batchTimeout)
Sets the batch timeout |
AggregateDefinition |
AggregateDefinition.collectionRef(String collectionRef)
Sets the aggregate collection to use |
AggregateDefinition |
AggregateDefinition.completionPredicate(Predicate predicate)
Sets the predicate used to determine if the aggregation is completed |
AggregateDefinition |
AggregateDefinition.groupExchanges()
Enables grouped exchanges, so the aggregator will group all aggregated exchanges into a single combined GroupedExchange class holding all the aggregated exchanges. |
AggregateDefinition |
AggregateDefinition.outBatchSize(int batchSize)
Sets the out batch size for number of exchanges sent |
AggregateDefinition |
AggregateDefinition.strategyRef(String strategyRef)
Sets the aggregate strategy to use |
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. |
ExpressionClause<AggregateDefinition> |
AggregateDefinition.completionPredicate()
Sets the predicate used to determine if the aggregation is completed |
ExpressionClause<AggregateDefinition> |
AggregateDefinition.createAndSetExpression()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |