org.mule.processor.strategy
Class QueuedAsynchronousProcessingStrategy
java.lang.Object
org.mule.processor.strategy.AsynchronousProcessingStrategy
org.mule.processor.strategy.QueuedAsynchronousProcessingStrategy
- All Implemented Interfaces:
- ProcessingStrategy, QueueStatisticsAware
- Direct Known Subclasses:
- DefaultFlowProcessingStrategy, QueuedThreadPerProcessorProcessingStrategy
public class QueuedAsynchronousProcessingStrategy
- extends AsynchronousProcessingStrategy
- implements QueueStatisticsAware
This strategy uses a QueueManager
to decouple receipt and processing of messages. The queue is
polled and a WorkManager
is used to schedule processing of the pipeline of message processors in a
single worker thread.
Methods inherited from class org.mule.processor.strategy.AsynchronousProcessingStrategy |
configureProcessors, 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 |
queueTimeout
protected Integer queueTimeout
maxQueueSize
protected Integer maxQueueSize
queueStore
protected QueueStore<Serializable> queueStore
queueStatistics
protected QueueStatistics queueStatistics
QueuedAsynchronousProcessingStrategy
public QueuedAsynchronousProcessingStrategy()
createAsyncMessageProcessor
protected AsyncInterceptingMessageProcessor createAsyncMessageProcessor(ProcessingStrategy.StageNameSource nameSource,
MuleContext muleContext)
- Overrides:
createAsyncMessageProcessor
in class AsynchronousProcessingStrategy
initQueueStore
protected void initQueueStore(MuleContext muleContext)
getQueueTimeout
public Integer getQueueTimeout()
setQueueTimeout
public void setQueueTimeout(Integer queueTimeout)
getMaxQueueSize
public Integer getMaxQueueSize()
setMaxQueueSize
public void setMaxQueueSize(Integer maxQueueSize)
getQueueStore
public QueueStore<Serializable> getQueueStore()
setQueueStore
public void setQueueStore(QueueStore<Serializable> queueStore)
getQueueStatistics
public QueueStatistics getQueueStatistics()
setQueueStatistics
public void setQueueStatistics(QueueStatistics queueStatistics)
- Specified by:
setQueueStatistics
in interface QueueStatisticsAware
Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.