public class AsyncInterceptingMessageProcessor extends AbstractInterceptingMessageProcessor implements Startable, Stoppable, MessagingExceptionHandlerAware
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.Modifier and Type | Field and Description |
---|---|
protected boolean |
doThreading |
static String |
SYNCHRONOUS_EVENT_ERROR_MESSAGE |
protected long |
threadTimeout |
protected WorkManager |
workManager |
protected WorkManagerSource |
workManagerSource |
logger, muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
AsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile,
String name,
int shutdownTimeout) |
AsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource) |
Modifier and Type | Method and Description |
---|---|
protected void |
fireAsyncScheduledNotification(MuleEvent event) |
protected void |
firePipelineNotification(MuleEvent event,
MessagingException exception) |
protected boolean |
isProcessAsync(MuleEvent event) |
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
protected void |
processNextAsync(MuleEvent event) |
protected MuleEvent |
processNextTimed(MuleEvent event) |
void |
setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler) |
void |
start() |
void |
stop() |
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public static final String SYNCHRONOUS_EVENT_ERROR_MESSAGE
protected WorkManagerSource workManagerSource
protected boolean doThreading
protected long threadTimeout
protected WorkManager workManager
public AsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource)
public AsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile, String name, int shutdownTimeout)
public void start() throws MuleException
start
in interface Startable
MuleException
public void stop() throws MuleException
stop
in interface Stoppable
MuleException
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
protected MuleEvent processNextTimed(MuleEvent event) throws MuleException
MuleException
protected boolean isProcessAsync(MuleEvent event) throws MessagingException
MessagingException
protected void processNextAsync(MuleEvent event) throws MuleException
MuleException
protected void fireAsyncScheduledNotification(MuleEvent event)
public void setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler)
setMessagingExceptionHandler
in interface MessagingExceptionHandlerAware
protected void firePipelineNotification(MuleEvent event, MessagingException exception)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.