org.apache.camel.model
Class AggregatorType
java.lang.Object
org.apache.camel.model.ProcessorType<ProcessorType>
org.apache.camel.model.ExpressionNode
org.apache.camel.model.AggregatorType
- All Implemented Interfaces:
- Block
public class AggregatorType
- extends ExpressionNode
- Version:
- $Revision: 36321 $
Methods inherited from class org.apache.camel.model.ProcessorType |
addInterceptor, addOutput, aggregator, aggregator, aggregator, aggregator, aggregator, bean, bean, bean, bean, beanRef, beanRef, choice, clearOutput, convertBodyTo, convertFaultBodyTo, convertOutBodyTo, createCompositeProcessor, createErrorHandlerBuilder, createOutputsProcessor, createOutputsProcessor, createProcessor, delayer, delayer, delayer, delayer, end, errorHandler, exception, filter, filter, filter, filter, getErrorHandlerBuilder, getInheritErrorHandlerFlag, getNodeFactory, getParent, handleFault, idempotentConsumer, idempotentConsumer, inheritErrorHandler, intercept, intercept, intercept, interceptor, interceptors, isInheritErrorHandler, loadBalance, makeProcessor, marshal, marshal, marshal, marshal, multicast, multicast, multicast, pipeline, pipeline, pipeline, policies, policy, popBlock, proceed, process, processRef, pushBlock, recipientList, recipientList, removeFaultHeader, removeHeader, removeOutHeader, removeProperty, resequencer, resequencer, resequencer, resequencer, routingSlip, routingSlip, routingSlip, setBody, setBody, setErrorHandlerBuilder, setFaultBody, setFaultHeader, setHeader, setHeader, setHeader, setInheritErrorHandlerFlag, setNodeFactory, setOutBody, setOutBody, setOutHeader, setOutHeader, setOutHeader, setParent, setProperty, setProperty, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, thread, thread, throttler, throwFault, throwFault, to, to, to, to, to, trace, trace, transform, transform, tryBlock, unmarshal, unmarshal, unmarshal, unmarshal, wrapInErrorHandler, wrapProcessor, wrapProcessorInInterceptors |
AggregatorType
public AggregatorType()
AggregatorType
public AggregatorType(Expression correlationExpression)
AggregatorType
public AggregatorType(ExpressionType correlationExpression)
AggregatorType
public AggregatorType(Expression correlationExpression,
AggregationStrategy aggregationStrategy)
toString
public String toString()
- Overrides:
toString
in class Object
addRoutes
public void addRoutes(RouteContext routeContext,
Collection<Route> routes)
throws Exception
- Overrides:
addRoutes
in class ProcessorType<ProcessorType>
- Throws:
Exception
getAggregationCollection
public AggregationCollection getAggregationCollection()
setAggregationCollection
public void setAggregationCollection(AggregationCollection aggregationCollection)
getAggregationStrategy
public AggregationStrategy getAggregationStrategy()
setAggregationStrategy
public void setAggregationStrategy(AggregationStrategy aggregationStrategy)
getBatchSize
public Integer getBatchSize()
setBatchSize
public void setBatchSize(Integer batchSize)
getBatchTimeout
public Long getBatchTimeout()
setBatchTimeout
public void setBatchTimeout(Long batchTimeout)
getStrategyRef
public String getStrategyRef()
setStrategyRef
public void setStrategyRef(String strategyRef)
getCompletePredicate
public CompletedPredicate getCompletePredicate()
setCompletePredicate
public void setCompletePredicate(CompletedPredicate completedPredicate)
batchSize
public AggregatorType batchSize(int batchSize)
batchTimeout
public AggregatorType batchTimeout(long batchTimeout)
completedPredicate
public ExpressionClause<AggregatorType> completedPredicate()
- Sets the predicate used to determine if the aggregation is completed
- Returns:
- the clause used to create the predicate
completedPredicate
public AggregatorType completedPredicate(Predicate predicate)
- Sets the predicate used to determine if the aggregation is completed
checkNoCompletedPredicate
protected void checkNoCompletedPredicate()
Copyright © 2008 IONA Open Source Community. All Rights Reserved.