org.mule.processor

Class AbstractNonBlockingMessageProcessor

java.lang.Object

org.mule.processor.AbstractNonBlockingMessageProcessor

All Implemented Interfaces:

MessagingExceptionHandlerAware, NonBlockingSupported, MessageProcessor, NonBlockingMessageProcessor

Direct Known Subclasses:

DefaultHttpRequester

public abstract class AbstractNonBlockingMessageProcessor
extends Object
implements NonBlockingMessageProcessor, MessagingExceptionHandlerAware

Abstract implementation of NonBlockingMessageProcessor that determines if processing should be performed blocking or non-blocking..

Constructor Summary

Constructors

Constructor and Description
AbstractNonBlockingMessageProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	isNonBlocking(MuleEvent event)
MuleEvent	process(MuleEvent event) Invokes the MessageProcessor.
protected abstract MuleEvent	processBlocking(MuleEvent event)
protected abstract void	processNonBlocking(MuleEvent event, CompletionHandler completionHandler)
void	setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractNonBlockingMessageProcessor

public AbstractNonBlockingMessageProcessor()

Method Detail

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

isNonBlocking

protected boolean isNonBlocking(MuleEvent event)

setMessagingExceptionHandler

public void setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler)

Specified by:

setMessagingExceptionHandler in interface MessagingExceptionHandlerAware

processNonBlocking

protected abstract void processNonBlocking(MuleEvent event,
                      CompletionHandler completionHandler)
                                    throws MuleException

Throws:

MuleException

processBlocking

protected abstract MuleEvent processBlocking(MuleEvent event)
                                      throws MuleException

Throws:

MuleException