org.apache.camel.model
Class AggregatorType

java.lang.Object
  extended by org.apache.camel.model.OptionalIdentifiedType<Type>
      extended by org.apache.camel.model.ProcessorType<ProcessorType>
          extended by org.apache.camel.model.ExpressionNode
              extended by org.apache.camel.model.AggregatorType
All Implemented Interfaces:
Block

public class AggregatorType
extends ExpressionNode

Represents an XML <aggregator/> element

Version:
$Revision: 1948 $

Field Summary
 
Fields inherited from class org.apache.camel.model.ProcessorType
DEFAULT_TRACE_CATEGORY
 
Fields inherited from class org.apache.camel.model.OptionalIdentifiedType
nodeCounters
 
Constructor Summary
AggregatorType()
           
AggregatorType(Expression correlationExpression)
           
AggregatorType(Expression correlationExpression, AggregationStrategy aggregationStrategy)
           
AggregatorType(ExpressionType correlationExpression)
           
 
Method Summary
 AggregatorType aggregationCollection(AggregationCollection aggregationCollection)
           
 AggregatorType aggregationStrategy(AggregationStrategy aggregationStrategy)
           
 AggregatorType batchSize(int batchSize)
           
 AggregatorType batchTimeout(long batchTimeout)
           
protected  void checkNoCompletedPredicate()
           
 ExpressionClause<AggregatorType> completedPredicate()
          Sets the predicate used to determine if the aggregation is completed
 AggregatorType completedPredicate(Predicate predicate)
          Sets the predicate used to determine if the aggregation is completed
protected  Aggregator createAggregator(RouteContext routeContext)
           
 Processor createProcessor(RouteContext routeContext)
           
 AggregationCollection getAggregationCollection()
           
 AggregationStrategy getAggregationStrategy()
           
 Integer getBatchSize()
           
 Long getBatchTimeout()
           
 ExpressionSubElementType getCompletedPredicate()
           
 Integer getOutBatchSize()
           
 String getShortName()
          Returns a short name for this node which can be useful for ID generation or referring to related resources like images
 String getStrategyRef()
           
 AggregatorType outBatchSize(int batchSize)
           
 void setAggregationCollection(AggregationCollection aggregationCollection)
           
 void setAggregationStrategy(AggregationStrategy aggregationStrategy)
           
 void setBatchSize(Integer batchSize)
           
 void setBatchTimeout(Long batchTimeout)
           
 void setCompletedPredicate(ExpressionSubElementType completedPredicate)
           
 void setOutBatchSize(Integer outBatchSize)
           
 void setStrategyRef(String strategyRef)
           
 AggregatorType strategyRef(String strategyRef)
           
 String toString()
           
 
Methods inherited from class org.apache.camel.model.ExpressionNode
configureChild, createFilterProcessor, getExpression, getLabel, getOutputs, setExpression, setOutputs
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AggregatorType

public AggregatorType()

AggregatorType

public AggregatorType(Expression correlationExpression)

AggregatorType

public AggregatorType(ExpressionType correlationExpression)

AggregatorType

public AggregatorType(Expression correlationExpression,
                      AggregationStrategy aggregationStrategy)
Method Detail

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 © 2009 IONA Open Source Community. All Rights Reserved.