org.mule.processor
Class AsyncInterceptingMessageProcessor
java.lang.Object
org.mule.processor.AbstractInterceptingMessageProcessorBase
org.mule.processor.AbstractInterceptingMessageProcessor
org.mule.processor.AsyncInterceptingMessageProcessor
- All Implemented Interfaces:
- AnnotatedObject, MuleContextAware, Startable, Stoppable, InterceptingMessageProcessor, MessageProcessor, MessageSource
- Direct Known Subclasses:
- LaxAsyncInterceptingMessageProcessor, SedaStageInterceptingMessageProcessor
public class AsyncInterceptingMessageProcessor
- extends AbstractInterceptingMessageProcessor
- implements Startable, Stoppable
Processes MuleEvent
's asynchronously using a MuleWorkManager
to
schedule asynchronous processing of the next MessageProcessor
. The next
MessageProcessor
is therefore be executed in a different thread regardless
of the exchange-pattern configured on the inbound endpoint. If a transaction is
present then an exception is thrown.
workManagerSource
protected WorkManagerSource workManagerSource
doThreading
protected boolean doThreading
workManager
protected WorkManager workManager
AsyncInterceptingMessageProcessor
public AsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource)
AsyncInterceptingMessageProcessor
public AsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile,
String name,
int shutdownTimeout)
start
public void start()
throws MuleException
- Specified by:
start
in interface Startable
- Throws:
MuleException
stop
public void stop()
throws MuleException
- Specified by:
stop
in interface Stoppable
- Throws:
MuleException
process
public MuleEvent process(MuleEvent event)
throws MuleException
- Description copied from interface:
MessageProcessor
- Invokes the MessageProcessor.
- Specified by:
process
in interface MessageProcessor
- Parameters:
event
- MuleEvent to be processed
- Returns:
- optional response MuleEvent
- Throws:
MuleException
processNextTimed
protected MuleEvent processNextTimed(MuleEvent event)
throws MuleException
- Throws:
MuleException
isProcessAsync
protected boolean isProcessAsync(MuleEvent event)
throws MessagingException
- Throws:
MessagingException
processNextAsync
protected void processNextAsync(MuleEvent event)
throws MuleException
- Throws:
MuleException
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.