org.mule.processor.strategy
Class AsynchronousProcessingStrategy

java.lang.Object
  org.mule.processor.strategy.AsynchronousProcessingStrategy

All Implemented Interfaces:

ProcessingStrategy

Direct Known Subclasses:

QueuedAsynchronousProcessingStrategy, ThreadPerProcessorProcessingStrategy

public class AsynchronousProcessingStrategy
extends Object
implements ProcessingStrategy

This strategy uses a WorkManager to schedule the processing of the pipeline of message processors in a single worker thread.

Nested Class Summary

Nested classes/interfaces inherited from interface org.mule.api.processor.ProcessingStrategy

ProcessingStrategy.StageNameSource

Field Summary

protected Integer	maxBufferSize
protected Integer	maxThreads
protected Integer	minThreads
protected Integer	poolExhaustedAction
protected ProcessingStrategy	synchronousProcessingStrategy
protected Long	threadTTL
protected Long	threadWaitTimeout

Constructor Summary

AsynchronousProcessingStrategy()

Method Summary

void	configureProcessors(List<MessageProcessor> processors, ProcessingStrategy.StageNameSource nameSource, MessageProcessorChainBuilder chainBuilder, MuleContext muleContext)
protected AsyncInterceptingMessageProcessor	createAsyncMessageProcessor(ProcessingStrategy.StageNameSource nameSource, MuleContext muleContext)
protected ThreadingProfile	createThreadingProfile(MuleContext muleContext)
Integer	getMaxBufferSize()
Integer	getMaxThreads()
Integer	getMinThreads()
Integer	getPoolExhaustedAction()
protected String	getThreadPoolName(String stageName, MuleContext muleContext)
Long	getThreadTTL()
Long	getThreadWaitTimeout()
void	setMaxBufferSize(Integer maxBufferSize)
void	setMaxThreads(Integer maxThreads)
void	setMinThreads(Integer minThreads)
void	setPoolExhaustedAction(Integer poolExhaustedAction)
void	setThreadTTL(Long threadTTL)
void	setThreadWaitTimeout(Long threadWaitTimeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

maxThreads

protected Integer maxThreads

minThreads

protected Integer minThreads

maxBufferSize

protected Integer maxBufferSize

threadTTL

protected Long threadTTL

threadWaitTimeout

protected Long threadWaitTimeout

poolExhaustedAction

protected Integer poolExhaustedAction

synchronousProcessingStrategy

protected ProcessingStrategy synchronousProcessingStrategy

Constructor Detail

AsynchronousProcessingStrategy

public AsynchronousProcessingStrategy()

Method Detail

configureProcessors

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

Specified by:

configureProcessors in interface ProcessingStrategy

createAsyncMessageProcessor

protected AsyncInterceptingMessageProcessor createAsyncMessageProcessor(ProcessingStrategy.StageNameSource nameSource,
                                                                        MuleContext muleContext)

createThreadingProfile

protected ThreadingProfile createThreadingProfile(MuleContext muleContext)

getThreadPoolName

protected String getThreadPoolName(String stageName,
                                   MuleContext muleContext)

getMaxThreads

public Integer getMaxThreads()

setMaxThreads

public void setMaxThreads(Integer maxThreads)

getMinThreads

public Integer getMinThreads()

setMinThreads

public void setMinThreads(Integer minThreads)

setMaxBufferSize

public void setMaxBufferSize(Integer maxBufferSize)

setThreadTTL

public void setThreadTTL(Long threadTTL)

setThreadWaitTimeout

public void setThreadWaitTimeout(Long threadWaitTimeout)

setPoolExhaustedAction

public void setPoolExhaustedAction(Integer poolExhaustedAction)

getMaxBufferSize

public Integer getMaxBufferSize()

getThreadTTL

public Long getThreadTTL()

getThreadWaitTimeout

public Long getThreadWaitTimeout()

getPoolExhaustedAction

public Integer getPoolExhaustedAction()