public class AsynchronousProcessingStrategy extends Object implements ProcessingStrategy
WorkManager
to schedule the processing of the pipeline of message processors
in a single worker thread.ProcessingStrategy.StageNameSource
Modifier and Type | Field and Description |
---|---|
protected Integer |
maxBufferSize |
protected Integer |
maxThreads |
protected Integer |
minThreads |
protected Integer |
poolExhaustedAction |
protected ProcessingStrategy |
synchronousProcessingStrategy |
protected Long |
threadTTL |
protected Long |
threadWaitTimeout |
Constructor and Description |
---|
AsynchronousProcessingStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder chainBuilder,
MuleContext muleContext) |
protected AsyncInterceptingMessageProcessor |
createAsyncMessageProcessor(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) |
protected Integer maxThreads
protected Integer minThreads
protected Integer maxBufferSize
protected Long threadTTL
protected Long threadWaitTimeout
protected Integer poolExhaustedAction
protected ProcessingStrategy synchronousProcessingStrategy
public void configureProcessors(List<MessageProcessor> processors, StageNameSource nameSource, MessageProcessorChainBuilder chainBuilder, MuleContext muleContext)
configureProcessors
in interface ProcessingStrategy
protected AsyncInterceptingMessageProcessor createAsyncMessageProcessor(StageNameSource nameSource, MuleContext muleContext)
protected ThreadingProfile createThreadingProfile(MuleContext muleContext)
protected String getThreadPoolName(String stageName, MuleContext muleContext)
public Integer getMaxThreads()
public void setMaxThreads(Integer maxThreads)
public Integer getMinThreads()
public void setMinThreads(Integer minThreads)
public void setMaxBufferSize(Integer maxBufferSize)
public void setThreadTTL(Long threadTTL)
public void setThreadWaitTimeout(Long threadWaitTimeout)
public void setPoolExhaustedAction(Integer poolExhaustedAction)
public Integer getMaxBufferSize()
public Long getThreadTTL()
public Long getThreadWaitTimeout()
public Integer getPoolExhaustedAction()
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.