org.apache.camel.model
Class AggregatorType
java.lang.Object
org.apache.camel.model.OptionalIdentifiedType<Type>
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
Represents an XML <aggregator/> element
- Version:
- $Revision: 1948 $
Methods inherited from class org.apache.camel.model.ProcessorType |
addInterceptor, addInterceptor, addOutput, addRoutes, aggregator, aggregator, aggregator, aggregator, aggregator, bean, bean, bean, bean, beanRef, beanRef, choice, clearOutput, convertBodyTo, convertBodyTo, convertFaultBodyTo, convertOutBodyTo, createCompositeProcessor, createErrorHandlerBuilder, createOutputsProcessor, createOutputsProcessor, delayer, delayer, delayer, delayer, end, errorHandler, exception, filter, filter, filter, filter, getErrorHandlerBuilder, getErrorHandlerRef, getInheritErrorHandlerFlag, getNodeFactory, getParent, handleFault, idempotentConsumer, idempotentConsumer, inheritErrorHandler, inOnly, inOnly, inOnly, inOnly, inOnly, inOnly, inOut, inOut, inOut, inOut, inOut, inOut, intercept, intercept, intercept, intercept, interceptor, interceptors, isInheritErrorHandler, isInheritErrorHandler, loadBalance, loop, loop, loop, makeProcessor, marshal, marshal, marshal, marshal, multicast, multicast, multicast, onException, pipeline, pipeline, pipeline, policies, policy, popBlock, proceed, process, processRef, pushBlock, recipientList, recipientList, removeFaultHeader, removeHeader, removeProperty, resequencer, resequencer, resequencer, resequencer, routingSlip, routingSlip, routingSlip, setBody, setBody, setErrorHandlerBuilder, setErrorHandlerBuilderIfNull, setErrorHandlerRef, setExchangePattern, setFaultBody, setFaultHeader, setHeader, setHeader, setHeader, setInheritErrorHandlerFlag, setNodeFactory, setOutBody, setOutBody, setOutHeader, setOutHeader, setParent, setProperty, setProperty, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, stop, thread, thread, throttler, throwFault, throwFault, to, to, to, to, to, to, to, to, to, to, trace, trace, transform, transform, tryBlock, unmarshal, unmarshal, unmarshal, unmarshal, wrapInErrorHandler, wrapProcessor, wrapProcessorInInterceptors |
Methods inherited from class org.apache.camel.model.OptionalIdentifiedType |
createId, describe, description, description, getDescription, getId, getNodeCounter, id, idOrCreate, setDescription, setId |
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
getShortName
public String getShortName()
- Description copied from class:
OptionalIdentifiedType
- Returns a short name for this node which can be useful for ID generation or referring to related resources like images
- Overrides:
getShortName
in class ExpressionNode
- Returns:
- defaults to "node" but derived nodes should overload this to provide a unique name
createProcessor
public Processor createProcessor(RouteContext routeContext)
throws Exception
- Overrides:
createProcessor
in class ProcessorType<ProcessorType>
- Throws:
Exception
createAggregator
protected Aggregator createAggregator(RouteContext routeContext)
throws Exception
- 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)
getOutBatchSize
public Integer getOutBatchSize()
setOutBatchSize
public void setOutBatchSize(Integer outBatchSize)
getBatchTimeout
public Long getBatchTimeout()
setBatchTimeout
public void setBatchTimeout(Long batchTimeout)
getStrategyRef
public String getStrategyRef()
setStrategyRef
public void setStrategyRef(String strategyRef)
setCompletedPredicate
public void setCompletedPredicate(ExpressionSubElementType completedPredicate)
getCompletedPredicate
public ExpressionSubElementType getCompletedPredicate()
batchSize
public AggregatorType batchSize(int batchSize)
outBatchSize
public AggregatorType outBatchSize(int batchSize)
batchTimeout
public AggregatorType batchTimeout(long batchTimeout)
aggregationCollection
public AggregatorType aggregationCollection(AggregationCollection aggregationCollection)
aggregationStrategy
public AggregatorType aggregationStrategy(AggregationStrategy aggregationStrategy)
strategyRef
public AggregatorType strategyRef(String strategyRef)
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 © 2010 IONA Open Source Community. All Rights Reserved.