public class LaxAsyncInterceptingMessageProcessor extends AsyncInterceptingMessageProcessor
doThreading, SYNCHRONOUS_EVENT_ERROR_MESSAGE, threadTimeout, workManager, workManagerSource
logger, muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
LaxAsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile,
String name,
int shutdownTimeout) |
LaxAsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
isProcessAsync(MuleEvent event) |
fireAsyncScheduledNotification, firePipelineNotification, process, processNextAsync, processNextTimed, setMessagingExceptionHandler, start, stop
addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, setMuleContext, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public LaxAsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource)
public LaxAsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile, String name, int shutdownTimeout)
protected boolean isProcessAsync(MuleEvent event) throws MessagingException
isProcessAsync
in class AsyncInterceptingMessageProcessor
MessagingException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.