org.mule.processor.strategy
Class ThreadPerProcessorProcessingStrategy

java.lang.Object
  org.mule.processor.strategy.AsynchronousProcessingStrategy
      org.mule.processor.strategy.ThreadPerProcessorProcessingStrategy

All Implemented Interfaces:

ProcessingStrategy

public class ThreadPerProcessorProcessingStrategy
extends AsynchronousProcessingStrategy

This strategy uses a WorkManager to schedule the processing of each message processors in a new worker thread.

Nested Class Summary

Nested classes/interfaces inherited from interface org.mule.api.processor.ProcessingStrategy

ProcessingStrategy.StageNameSource

Field Summary

Fields inherited from class org.mule.processor.strategy.AsynchronousProcessingStrategy

maxBufferSize, maxThreads, minThreads, poolExhaustedAction, synchronousProcessingStrategy, threadTTL, threadWaitTimeout

Constructor Summary

ThreadPerProcessorProcessingStrategy()

Method Summary

void	configureProcessors(List<MessageProcessor> processors, ProcessingStrategy.StageNameSource nameSource, MessageProcessorChainBuilder builder, MuleContext muleContext)

Methods inherited from class org.mule.processor.strategy.AsynchronousProcessingStrategy

createAsyncMessageProcessor, createThreadingProfile, getMaxBufferSize, getMaxThreads, getMinThreads, getPoolExhaustedAction, getThreadPoolName, getThreadTTL, getThreadWaitTimeout, setMaxBufferSize, setMaxThreads, setMinThreads, setPoolExhaustedAction, setThreadTTL, setThreadWaitTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadPerProcessorProcessingStrategy

public ThreadPerProcessorProcessingStrategy()

Method Detail

configureProcessors

public void configureProcessors(List<MessageProcessor> processors,
                                ProcessingStrategy.StageNameSource nameSource,
                                MessageProcessorChainBuilder builder,
                                MuleContext muleContext)

Specified by:

configureProcessors in interface ProcessingStrategy

Overrides:

configureProcessors in class AsynchronousProcessingStrategy