public class SimpleAsyncRequestReplyRequester extends AbstractAsyncRequestReplyRequester implements Startable, Stoppable
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
requestMessageProcessor |
failOnTimeout, flowConstruct, locks, MAX_PROCESSED_GROUPS, name, NAME_TEMPLATE, processed, processedLock, replyMessageSource, responseEvents, store, timeout, UNCLAIMED_INTERVAL, UNCLAIMED_TIME_TO_LIVE
logger, muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
SimpleAsyncRequestReplyRequester() |
Modifier and Type | Method and Description |
---|---|
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) |
addProcessed, createEventLock, dispose, getAsyncReplyCorrelationId, initialise, isAlreadyProcessed, postLatchAwait, process, receiveAsyncReply, setFailOnTimeout, setFlowConstruct, setReplySource, setStorePrefix, setTimeout, toString
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener
getAnnotation, getAnnotations, setAnnotations
protected MessageProcessor requestMessageProcessor
protected void sendAsyncRequest(MuleEvent event) throws MuleException
sendAsyncRequest
in class AbstractAsyncRequestReplyRequester
MuleException
protected void setAsyncReplyProperties(MuleEvent event) throws MuleException
MuleException
protected void verifyReplyMessageSource(MessageSource messageSource)
verifyReplyMessageSource
in class AbstractAsyncRequestReplyRequester
public void setMessageProcessor(MessageProcessor processor)
@Deprecated public void setMessageSource(MessageSource source)
public void start() throws MuleException
start
in interface Startable
start
in class AbstractAsyncRequestReplyRequester
MuleException
public void stop() throws MuleException
stop
in interface Stoppable
stop
in class AbstractAsyncRequestReplyRequester
MuleException
public void setMuleContext(MuleContext context)
setMuleContext
in interface MuleContextAware
setMuleContext
in class AbstractInterceptingMessageProcessorBase
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.