org.apache.camel.model
Class MulticastType

java.lang.Object
  extended by org.apache.camel.model.ProcessorType<Type>
      extended by org.apache.camel.model.OutputType<ProcessorType>
          extended by org.apache.camel.model.MulticastType
All Implemented Interfaces:
Block

public class MulticastType
extends OutputType<ProcessorType>

Version:
$Revision: 36321 $

Field Summary
 
Fields inherited from class org.apache.camel.model.OutputType
outputs
 
Fields inherited from class org.apache.camel.model.ProcessorType
DEFAULT_TRACE_CATEGORY
 
Constructor Summary
MulticastType()
           
 
Method Summary
protected  Processor createCompositeProcessor(List<Processor> list)
          Creates a new instance of some kind of composite processor which defaults to using a Pipeline but derived classes could change the behaviour
 Processor createProcessor(RouteContext routeContext)
           
 AggregationStrategy getAggregationStrategy()
           
 ThreadPoolExecutor getThreadPoolExecutor()
           
 boolean isParallelProcessing()
           
 void setAggregationStrategy(AggregationStrategy aggregationStrategy)
           
 void setParallelProcessing(boolean parallelProcessing)
           
 void setThreadPoolExecutor(ThreadPoolExecutor executor)
           
 String toString()
           
 
Methods inherited from class org.apache.camel.model.OutputType
configureChild, getOutputs, setOutputs
 
Methods inherited from class org.apache.camel.model.ProcessorType
addInterceptor, addOutput, addRoutes, aggregator, aggregator, aggregator, aggregator, aggregator, bean, bean, bean, bean, beanRef, beanRef, choice, clearOutput, convertBodyTo, convertFaultBodyTo, convertOutBodyTo, createErrorHandlerBuilder, createOutputsProcessor, createOutputsProcessor, delayer, delayer, delayer, delayer, end, errorHandler, exception, filter, filter, filter, filter, getErrorHandlerBuilder, getInheritErrorHandlerFlag, getLabel, 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

MulticastType

public MulticastType()
Method Detail

toString

public String toString()
Overrides:
toString in class Object

createProcessor

public Processor createProcessor(RouteContext routeContext)
                          throws Exception
Overrides:
createProcessor in class ProcessorType<ProcessorType>
Throws:
Exception

createCompositeProcessor

protected Processor createCompositeProcessor(List<Processor> list)
Description copied from class: ProcessorType
Creates a new instance of some kind of composite processor which defaults to using a Pipeline but derived classes could change the behaviour

Overrides:
createCompositeProcessor in class ProcessorType<ProcessorType>

getAggregationStrategy

public AggregationStrategy getAggregationStrategy()

setAggregationStrategy

public void setAggregationStrategy(AggregationStrategy aggregationStrategy)

isParallelProcessing

public boolean isParallelProcessing()

setParallelProcessing

public void setParallelProcessing(boolean parallelProcessing)

getThreadPoolExecutor

public ThreadPoolExecutor getThreadPoolExecutor()

setThreadPoolExecutor

public void setThreadPoolExecutor(ThreadPoolExecutor executor)


Copyright © 2008 IONA Open Source Community. All Rights Reserved.