org.mule.construct.flow
Class DefaultFlowProcessingStrategy
java.lang.Object
org.mule.processor.strategy.AsynchronousProcessingStrategy
org.mule.processor.strategy.QueuedAsynchronousProcessingStrategy
org.mule.construct.flow.DefaultFlowProcessingStrategy
- All Implemented Interfaces:
- ProcessingStrategy, QueueStatisticsAware
public class DefaultFlowProcessingStrategy
- extends QueuedAsynchronousProcessingStrategy
This processing strategy uses the 'queued-asynchronous' strategy where possible, but if an event is
synchronous it processes it synchronously rather than failing.
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 |
DefaultFlowProcessingStrategy
public DefaultFlowProcessingStrategy()
createAsyncMessageProcessor
protected AsyncInterceptingMessageProcessor createAsyncMessageProcessor(ProcessingStrategy.StageNameSource nameSource,
MuleContext muleContext)
- Overrides:
createAsyncMessageProcessor
in class QueuedAsynchronousProcessingStrategy
Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.