org.mule.processor

Class AsyncInterceptingMessageProcessor

java.lang.Object

org.mule.AbstractAnnotatedObject

org.mule.processor.AbstractInterceptingMessageProcessorBase

org.mule.processor.AbstractInterceptingMessageProcessor

org.mule.processor.AsyncInterceptingMessageProcessor

All Implemented Interfaces:

AnnotatedObject, MuleContextAware, MessagingExceptionHandlerAware, Startable, Stoppable, NonBlockingSupported, InterceptingMessageProcessor, MessageProcessor, MessageProcessorContainer, MessageSource

Direct Known Subclasses:

LaxAsyncInterceptingMessageProcessor, SedaStageInterceptingMessageProcessor

public class AsyncInterceptingMessageProcessor
extends AbstractInterceptingMessageProcessor
implements Startable, Stoppable, MessagingExceptionHandlerAware, NonBlockingSupported

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.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	doThreading
static String	SYNCHRONOUS_NONBLOCKING_EVENT_ERROR_MESSAGE
protected long	threadTimeout
protected WorkManager	workManager
protected WorkManagerSource	workManagerSource

Fields inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

logger, muleContext, next, notificationHandler

Fields inherited from interface org.mule.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Stoppable

PHASE_NAME

Fields inherited from interface org.mule.api.AnnotatedObject

PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
AsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile, String name, int shutdownTimeout)
AsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	canProcessAsync(MuleEvent event)
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()

Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString

Methods inherited from class org.mule.AbstractAnnotatedObject

getAnnotation, getAnnotations, setAnnotations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.mule.api.source.MessageSource

setListener

Field Detail

SYNCHRONOUS_NONBLOCKING_EVENT_ERROR_MESSAGE

public static final String SYNCHRONOUS_NONBLOCKING_EVENT_ERROR_MESSAGE

See Also:

Constant Field Values

workManagerSource

protected WorkManagerSource workManagerSource

doThreading

protected boolean doThreading

threadTimeout

protected long threadTimeout

workManager

protected WorkManager workManager

Constructor Detail

AsyncInterceptingMessageProcessor

public AsyncInterceptingMessageProcessor(WorkManagerSource workManagerSource)

AsyncInterceptingMessageProcessor

public AsyncInterceptingMessageProcessor(ThreadingProfile threadingProfile,
                                 String name,
                                 int shutdownTimeout)

Method Detail

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

canProcessAsync

protected boolean canProcessAsync(MuleEvent event)
                           throws MessagingException

Throws:

MessagingException

processNextAsync

protected void processNextAsync(MuleEvent event)
                         throws MuleException

Throws:

MuleException

fireAsyncScheduledNotification

protected void fireAsyncScheduledNotification(MuleEvent event)

setMessagingExceptionHandler

public void setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler)

Specified by:

setMessagingExceptionHandler in interface MessagingExceptionHandlerAware

firePipelineNotification

protected void firePipelineNotification(MuleEvent event,
                            MessagingException exception)