public class AsynchronousProcessingStrategy extends AbstractThreadingProfileProcessingStrategy
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 ProcessingStrategy |
synchronousProcessingStrategy |
maxBufferSize, maxThreads, minThreads, poolExhaustedAction, threadTTL, 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) |
createThreadingProfile, getMaxBufferSize, getMaxThreads, getMinThreads, getPoolExhaustedAction, getThreadPoolName, getThreadTTL, getThreadWaitTimeout, setMaxBufferSize, setMaxThreads, setMinThreads, setPoolExhaustedAction, setThreadTTL, setThreadWaitTimeout
protected ProcessingStrategy synchronousProcessingStrategy
public void configureProcessors(List<MessageProcessor> processors, StageNameSource nameSource, MessageProcessorChainBuilder chainBuilder, MuleContext muleContext)
protected AsyncInterceptingMessageProcessor createAsyncMessageProcessor(StageNameSource nameSource, MuleContext muleContext)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.