org.mule.routing.requestreply
Class SimpleAsyncRequestReplyRequester

java.lang.Object
  org.mule.processor.AbstractInterceptingMessageProcessorBase
      org.mule.routing.requestreply.AbstractAsyncRequestReplyRequester
          org.mule.routing.requestreply.SimpleAsyncRequestReplyRequester

All Implemented Interfaces:

AnnotatedObject, FlowConstructAware, MuleContextAware, Disposable, Initialisable, Startable, Stoppable, MessageProcessor, RequestReplyRequesterMessageProcessor

public class SimpleAsyncRequestReplyRequester
extends AbstractAsyncRequestReplyRequester
implements Startable, Stoppable

Field Summary

protected MessageProcessor

requestMessageProcessor

Fields inherited from class org.mule.routing.requestreply.AbstractAsyncRequestReplyRequester

failOnTimeout, flowConstruct, locks, MAX_PROCESSED_GROUPS, name, NAME_TEMPLATE, processed, processedLock, replyMessageSource, responseEvents, store, timeout, UNCLAIMED_INTERVAL, UNCLAIMED_TIME_TO_LIVE

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.lifecycle.Initialisable

PHASE_NAME

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

PHASE_NAME

Fields inherited from interface org.mule.api.AnnotatedObject

PROPERTY_NAME

Constructor Summary

SimpleAsyncRequestReplyRequester()

Method Summary

protected void	sendAsyncRequest(MuleEvent event)
protected void	setAsyncReplyProperties(MuleEvent event)
void	setMessageProcessor(MessageProcessor processor)
void	setMessageSource(MessageSource source) Deprecated.
void	setMuleContext(MuleContext context)
void	start()
void	stop()
protected void	verifyReplyMessageSource(MessageSource messageSource)

Methods inherited from class org.mule.routing.requestreply.AbstractAsyncRequestReplyRequester

addProcessed, dispose, getAsyncReplyCorrelationId, initialise, isAlreadyProcessed, postLatchAwait, process, receiveAsyncReply, setFailOnTimeout, setFlowConstruct, setReplySource, setStorePrefix, setTimeout, toString

Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener

Methods inherited from class java.lang.Object

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

Field Detail

requestMessageProcessor

protected MessageProcessor requestMessageProcessor

Constructor Detail

SimpleAsyncRequestReplyRequester

public SimpleAsyncRequestReplyRequester()

Method Detail

sendAsyncRequest

protected void sendAsyncRequest(MuleEvent event)
                         throws MuleException

Overrides:

sendAsyncRequest in class AbstractAsyncRequestReplyRequester

Throws:

MuleException

setAsyncReplyProperties

protected void setAsyncReplyProperties(MuleEvent event)
                                throws MuleException

Throws:

MuleException

verifyReplyMessageSource

protected void verifyReplyMessageSource(MessageSource messageSource)

Overrides:

verifyReplyMessageSource in class AbstractAsyncRequestReplyRequester

setMessageProcessor

public void setMessageProcessor(MessageProcessor processor)

setMessageSource

@Deprecated
public void setMessageSource(MessageSource source)

Deprecated.

start

public void start()
           throws MuleException

Specified by:

start in interface Startable

Overrides:

start in class AbstractAsyncRequestReplyRequester

Throws:

MuleException

stop

public void stop()
          throws MuleException

Specified by:

stop in interface Stoppable

Overrides:

stop in class AbstractAsyncRequestReplyRequester

Throws:

MuleException

setMuleContext

public void setMuleContext(MuleContext context)

Specified by:

setMuleContext in interface MuleContextAware

Overrides:

setMuleContext in class AbstractInterceptingMessageProcessorBase