|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AggregationStrategy | |
---|---|
org.apache.camel.model | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. |
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. |
Uses of AggregationStrategy in org.apache.camel.model |
---|
Methods in org.apache.camel.model that return AggregationStrategy | |
---|---|
AggregationStrategy |
AggregatorType.getAggregationStrategy()
|
Methods in org.apache.camel.model with parameters of type AggregationStrategy | |
---|---|
AggregatorType |
ProcessorType.aggregator(Expression correlationExpression,
AggregationStrategy aggregationStrategy)
A builder for the 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 {@link AggregationStrategy ) (by default the latest message is used) to compress many message exchanges into a smaller number of exchanges. |
void |
AggregatorType.setAggregationStrategy(AggregationStrategy aggregationStrategy)
|
Constructors in org.apache.camel.model with parameters of type AggregationStrategy | |
---|---|
AggregatorType(Expression correlationExpression,
AggregationStrategy aggregationStrategy)
|
Uses of AggregationStrategy in org.apache.camel.processor |
---|
Constructors in org.apache.camel.processor with parameters of type AggregationStrategy | |
---|---|
Aggregator(Endpoint endpoint,
Processor processor,
Expression correlationExpression,
AggregationStrategy aggregationStrategy)
|
Uses of AggregationStrategy in org.apache.camel.processor.aggregate |
---|
Classes in org.apache.camel.processor.aggregate that implement AggregationStrategy | |
---|---|
class |
UseLatestAggregationStrategy
An AggregationStrategy which just uses the latest exchange which is useful
for status messages where old status messages have no real value; another example is things
like market data prices, where old stock prices are not that relevant, only the current price is. |
Constructors in org.apache.camel.processor.aggregate with parameters of type AggregationStrategy | |
---|---|
AggregationCollection(Expression<Exchange> correlationExpression,
AggregationStrategy aggregationStrategy)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |