org.mule.processor.strategy

Class AbstractThreadingProfileProcessingStrategy

java.lang.Object

org.mule.processor.strategy.AbstractThreadingProfileProcessingStrategy

All Implemented Interfaces:

ProcessingStrategy

Direct Known Subclasses:

AsynchronousProcessingStrategy, NonBlockingProcessingStrategy

public abstract class AbstractThreadingProfileProcessingStrategy
extends Object
implements ProcessingStrategy

A abstract ProcessingStrategy implementation that provides a ThreadingProfile for you in extensions configured via setters for each of the threading profile attributes.

Nested Class Summary

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

ProcessingStrategy.StageNameSource

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	maxBufferSize
protected Integer	maxThreads
protected Integer	minThreads
protected Integer	poolExhaustedAction
protected Long	threadTTL
protected Long	threadWaitTimeout

Constructor Summary

Constructors

Constructor and Description
AbstractThreadingProfileProcessingStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
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

Methods inherited from interface org.mule.api.processor.ProcessingStrategy

configureProcessors

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

Constructor Detail

AbstractThreadingProfileProcessingStrategy

public AbstractThreadingProfileProcessingStrategy()

Method Detail

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()