public class LaxSedaStageInterceptingMessageProcessor extends SedaStageInterceptingMessageProcessor implements javax.resource.spi.work.Work, Lifecycle, Pausable, Resumable, NonBlockingSupported
MuleEvent
's asynchronously using a MuleWorkManager
to schedule asynchronous
processing of the next MessageProcessor
.DEFAULT_QUEUE_SIZE_MAX_THREADS_FACTOR, lifecycleManager, queue, QUEUE_NAME_PREFIX, queueConfiguration, queueName, queueProfile, queueStatistics, queueTimeout
doThreading, SYNCHRONOUS_EVENT_ERROR_MESSAGE, threadTimeout, workManager, workManagerSource
logger, muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
LaxSedaStageInterceptingMessageProcessor(String name,
String queueName,
QueueProfile queueProfile,
int queueTimeout,
ThreadingProfile threadingProfile,
QueueStatistics queueStatistics,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
isProcessAsync(MuleEvent event) |
configureDefaultQueueSize, dequeue, dispose, enqueue, getQueueName, getQueueSize, getStageDescription, getStageName, initialise, isQueuePersistent, isStatsEnabled, pause, processNextAsync, release, resume, rollbackDequeue, run, start, stop, waitIfPaused
fireAsyncScheduledNotification, firePipelineNotification, process, processNextTimed, setMessagingExceptionHandler
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
release
initialise
dispose
setListener
public LaxSedaStageInterceptingMessageProcessor(String name, String queueName, QueueProfile queueProfile, int queueTimeout, ThreadingProfile threadingProfile, QueueStatistics queueStatistics, MuleContext muleContext)
protected boolean isProcessAsync(MuleEvent event) throws MessagingException
isProcessAsync
in class AsyncInterceptingMessageProcessor
MessagingException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.