|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AggregationStrategy | |
---|---|
org.apache.camel.model | The JAXB POJOs for the XML Configuration of the routing rules. |
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()
|
AggregationStrategy |
SplitterType.getAggregationStrategy()
|
AggregationStrategy |
MulticastType.getAggregationStrategy()
|
Methods in org.apache.camel.model with parameters of type AggregationStrategy | |
---|---|
AggregatorType |
AggregatorType.aggregationStrategy(AggregationStrategy aggregationStrategy)
|
SplitterType |
SplitterType.aggregationStrategy(AggregationStrategy aggregationStrategy)
Set the spliter's aggregationStrategy |
MulticastType |
MulticastType.aggregationStrategy(AggregationStrategy aggregationStrategy)
Set the multicasting aggregationStrategy |
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. |
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. |
MulticastType |
ProcessorType.multicast(AggregationStrategy aggregationStrategy)
Multicasts messages to all its child outputs; so that each processor and destination gets a copy of the original message to avoid the processors interfering with each other. |
MulticastType |
ProcessorType.multicast(AggregationStrategy aggregationStrategy,
boolean parallelProcessing)
Multicasts messages to all its child outputs; so that each processor and destination gets a copy of the original message to avoid the processors interfering with each other. |
void |
AggregatorType.setAggregationStrategy(AggregationStrategy aggregationStrategy)
|
void |
SplitterType.setAggregationStrategy(AggregationStrategy aggregationStrategy)
|
void |
MulticastType.setAggregationStrategy(AggregationStrategy aggregationStrategy)
|
ExpressionClause<SplitterType> |
ProcessorType.splitter(AggregationStrategy aggregationStrategy)
Creates the Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint. |
ExpressionClause<SplitterType> |
ProcessorType.splitter(AggregationStrategy aggregationStrategy,
boolean parallelProcessing)
Creates the Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint. |
ExpressionClause<SplitterType> |
ProcessorType.splitter(AggregationStrategy aggregationStrategy,
boolean parallelProcessing,
ThreadPoolExecutor threadPoolExecutor)
Creates the Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint. |
SplitterType |
ProcessorType.splitter(Expression partsExpression,
AggregationStrategy aggregationStrategy)
Creates the Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint. |
SplitterType |
ProcessorType.splitter(Expression partsExpression,
AggregationStrategy aggregationStrategy,
boolean parallelProcessing)
Creates the Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint. |
SplitterType |
ProcessorType.splitter(Expression partsExpression,
AggregationStrategy aggregationStrategy,
boolean parallelProcessing,
ThreadPoolExecutor threadPoolExecutor)
Creates the Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint. |
Constructors in org.apache.camel.model with parameters of type AggregationStrategy | |
---|---|
AggregatorType(Expression correlationExpression,
AggregationStrategy aggregationStrategy)
|
Uses of AggregationStrategy in org.apache.camel.processor |
---|
Methods in org.apache.camel.processor that return AggregationStrategy | |
---|---|
AggregationStrategy |
MulticastProcessor.getAggregationStrategy()
|
Constructors in org.apache.camel.processor with parameters of type AggregationStrategy | |
---|---|
Aggregator(Processor processor,
Expression correlationExpression,
AggregationStrategy aggregationStrategy)
|
|
Aggregator(Processor processor,
Expression correlationExpression,
AggregationStrategy aggregationStrategy,
Predicate aggregationCompletedPredicate)
|
|
MulticastProcessor(Collection<Processor> processors,
AggregationStrategy aggregationStrategy)
|
|
MulticastProcessor(Collection<Processor> processors,
AggregationStrategy aggregationStrategy,
boolean parallelProcessing,
ThreadPoolExecutor executor)
|
|
MulticastProcessor(Collection<Processor> processors,
AggregationStrategy aggregationStrategy,
boolean parallelProcessing,
ThreadPoolExecutor executor,
boolean streaming)
|
|
Splitter(Expression expression,
Processor destination,
AggregationStrategy aggregationStrategy)
|
|
Splitter(Expression expression,
Processor destination,
AggregationStrategy aggregationStrategy,
boolean parallelProcessing,
ThreadPoolExecutor threadPoolExecutor,
boolean streaming)
|
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. |
Methods in org.apache.camel.processor.aggregate that return AggregationStrategy | |
---|---|
AggregationStrategy |
DefaultAggregationCollection.getAggregationStrategy()
|
AggregationStrategy |
AggregationCollection.getAggregationStrategy()
Gets the aggregation strategy |
Methods in org.apache.camel.processor.aggregate with parameters of type AggregationStrategy | |
---|---|
void |
DefaultAggregationCollection.setAggregationStrategy(AggregationStrategy aggregationStrategy)
|
void |
AggregationCollection.setAggregationStrategy(AggregationStrategy aggregationStrategy)
Sets the aggregation strategy to be used |
Constructors in org.apache.camel.processor.aggregate with parameters of type AggregationStrategy | |
---|---|
DefaultAggregationCollection(Expression<Exchange> correlationExpression,
AggregationStrategy aggregationStrategy)
|
|
PredicateAggregationCollection(Expression<Exchange> correlationExpression,
AggregationStrategy aggregationStrategy,
Predicate aggregationCompletedPredicate)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |