org.apache.camel.model
Class AggregatorType

java.lang.Object
  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

Version:
$Revision: 36321 $

Field Summary
 
Fields inherited from class org.apache.camel.model.ProcessorType
DEFAULT_TRACE_CATEGORY
 
Constructor Summary
AggregatorType()
           
AggregatorType(Expression correlationExpression)
           
AggregatorType(Expression correlationExpression, AggregationStrategy aggregationStrategy)
           
AggregatorType(ExpressionType correlationExpression)
           
 
Method Summary
 void addRoutes(RouteContext routeContext, Collection<Route> routes)
           
 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
 AggregationCollection getAggregationCollection()
           
 AggregationStrategy getAggregationStrategy()
           
 Integer getBatchSize()
           
 Long getBatchTimeout()
           
 CompletedPredicate getCompletePredicate()
           
 String getStrategyRef()
           
 void setAggregationCollection(AggregationCollection aggregationCollection)
           
 void setAggregationStrategy(AggregationStrategy aggregationStrategy)
           
 void setBatchSize(Integer batchSize)
           
 void setBatchTimeout(Long batchTimeout)
           
 void setCompletePredicate(CompletedPredicate completedPredicate)
           
 void setStrategyRef(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, 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
 
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

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.