org.mule.construct.flow
Class DefaultFlowProcessingStrategy

java.lang.Object
  extended by org.mule.processor.strategy.AsynchronousProcessingStrategy
      extended by org.mule.processor.strategy.QueuedAsynchronousProcessingStrategy
          extended by 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
maxBufferSize, maxThreads, minThreads, poolExhaustedAction, synchronousProcessingStrategy, threadTTL, threadWaitTimeout
 
Constructor Summary
DefaultFlowProcessingStrategy()
           
 
Method Summary
protected  AsyncInterceptingMessageProcessor createAsyncMessageProcessor(ProcessingStrategy.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, 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(ProcessingStrategy.StageNameSource nameSource,
                                                                        MuleContext muleContext)
Overrides:
createAsyncMessageProcessor in class QueuedAsynchronousProcessingStrategy


Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.