org.mule.processor
Class LaxSedaStageInterceptingMessageProcessor
java.lang.Object
org.mule.processor.AbstractInterceptingMessageProcessorBase
org.mule.processor.AbstractInterceptingMessageProcessor
org.mule.processor.AsyncInterceptingMessageProcessor
org.mule.processor.SedaStageInterceptingMessageProcessor
org.mule.processor.LaxSedaStageInterceptingMessageProcessor
- All Implemented Interfaces:
- Runnable, javax.resource.spi.work.Work, AnnotatedObject, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, InterceptingMessageProcessor, MessageProcessor, MessageProcessorContainer, MessageSource, Pausable, Resumable
public class LaxSedaStageInterceptingMessageProcessor
- extends SedaStageInterceptingMessageProcessor
- implements javax.resource.spi.work.Work, Lifecycle, Pausable, Resumable
Processes MuleEvent
's asynchronously using a MuleWorkManager
to schedule asynchronous
processing of the next MessageProcessor
.
Methods inherited from class org.mule.processor.SedaStageInterceptingMessageProcessor |
dequeue, dispose, enqueue, getQueueName, getQueueSize, getStageDescription, getStageName, initialise, isQueuePersistent, isStatsEnabled, pause, processNextAsync, release, resume, rollbackDequeue, run, start, stop, waitIfPaused |
Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase |
addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, setMuleContext, toString |
Methods inherited from interface javax.resource.spi.work.Work |
release |
Methods inherited from interface java.lang.Runnable |
run |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
LaxSedaStageInterceptingMessageProcessor
public LaxSedaStageInterceptingMessageProcessor(String name,
String queueName,
QueueProfile queueProfile,
int queueTimeout,
ThreadingProfile threadingProfile,
QueueStatistics queueStatistics,
MuleContext muleContext)
isProcessAsync
protected boolean isProcessAsync(MuleEvent event)
throws MessagingException
- Overrides:
isProcessAsync
in class AsyncInterceptingMessageProcessor
- Throws:
MessagingException
Copyright © 2003-2013 MuleSoft, Inc.. All Rights Reserved.