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
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 |
Methods inherited from class org.mule.routing.requestreply.AbstractAsyncRequestReplyRequester |
addProcessed, dispose, getAsyncReplyCorrelationId, initialise, isAlreadyProcessed, postLatchAwait, process, receiveAsyncReply, setFailOnTimeout, setFlowConstruct, setReplySource, setStorePrefix, setTimeout, toString |
requestMessageProcessor
protected MessageProcessor requestMessageProcessor
SimpleAsyncRequestReplyRequester
public SimpleAsyncRequestReplyRequester()
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
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.