org.mule.processor.strategy

Class NonBlockingProcessingStrategy

java.lang.Object

org.mule.processor.strategy.AbstractThreadingProfileProcessingStrategy

org.mule.processor.strategy.NonBlockingProcessingStrategy

All Implemented Interfaces:

ProcessingStrategy

public class NonBlockingProcessingStrategy
extends AbstractThreadingProfileProcessingStrategy

Allows Mule to use non-blocking execution model where possible and free up threads when performing IO operations.

Since:

3.7

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.AbstractThreadingProfileProcessingStrategy

maxBufferSize, maxThreads, minThreads, poolExhaustedAction, threadTTL, threadWaitTimeout

Constructor Summary

Constructors

Constructor and Description
NonBlockingProcessingStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
void	configureProcessors(List<MessageProcessor> processors, StageNameSource nameSource, MessageProcessorChainBuilder chainBuilder, MuleContext muleContext)
WorkManager	createWorkManager(FlowConstruct flowConstruct)

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

NonBlockingProcessingStrategy

public NonBlockingProcessingStrategy()

Method Detail

configureProcessors

public void configureProcessors(List<MessageProcessor> processors,
                       StageNameSource nameSource,
                       MessageProcessorChainBuilder chainBuilder,
                       MuleContext muleContext)

createWorkManager

public WorkManager createWorkManager(FlowConstruct flowConstruct)