org.mule.processor.strategy
Class QueuedThreadPerProcessorProcessingStrategy

java.lang.Object
  org.mule.processor.strategy.AsynchronousProcessingStrategy
      org.mule.processor.strategy.QueuedAsynchronousProcessingStrategy
          org.mule.processor.strategy.QueuedThreadPerProcessorProcessingStrategy

All Implemented Interfaces:

ProcessingStrategy, QueueStatisticsAware

public class QueuedThreadPerProcessorProcessingStrategy
extends QueuedAsynchronousProcessingStrategy

This strategy uses the QueueManager to decouple the processing of each message processor. Each queue is polled and a WorkManager is used to schedule processing of the 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.QueuedAsynchronousProcessingStrategy

maxQueueSize, queueStatistics, queueStore, queueTimeout

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

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

Constructor Summary

QueuedThreadPerProcessorProcessingStrategy()

Method Summary

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

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

createAsyncMessageProcessor, getMaxQueueSize, getQueueStatistics, getQueueStore, getQueueTimeout, initQueueStore, setMaxQueueSize, setQueueStatistics, setQueueStore, setQueueTimeout

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

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

QueuedThreadPerProcessorProcessingStrategy

public QueuedThreadPerProcessorProcessingStrategy()

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