org.mule.construct.flow

Class DefaultFlowProcessingStrategy

java.lang.Object

org.mule.processor.strategy.AbstractThreadingProfileProcessingStrategy

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.

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

synchronousProcessingStrategy

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

maxBufferSize, maxThreads, minThreads, poolExhaustedAction, threadTTL, threadWaitTimeout

Constructor Summary

Constructors

Constructor and Description
DefaultFlowProcessingStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
protected AsyncInterceptingMessageProcessor	createAsyncMessageProcessor(StageNameSource nameSource, MuleContext muleContext)

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

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

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

configureProcessors

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

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

DefaultFlowProcessingStrategy

public DefaultFlowProcessingStrategy()

Method Detail

createAsyncMessageProcessor

protected AsyncInterceptingMessageProcessor createAsyncMessageProcessor(StageNameSource nameSource,
                                                            MuleContext muleContext)

Overrides:

createAsyncMessageProcessor in class QueuedAsynchronousProcessingStrategy