org.mule.service.processor
Class ServiceAsyncRequestReplyRequestor
java.lang.Object
org.mule.processor.AbstractInterceptingMessageProcessorBase
org.mule.routing.requestreply.AbstractAsyncRequestReplyRequester
org.mule.service.processor.ServiceAsyncRequestReplyRequestor
- All Implemented Interfaces:
- AnnotatedObject, FlowConstructAware, MuleContextAware, Disposable, Initialisable, Startable, Stoppable, InterceptingMessageProcessor, MessageProcessor, RequestReplyRequesterMessageProcessor, MessageSource
public class ServiceAsyncRequestReplyRequestor
- extends AbstractAsyncRequestReplyRequester
- implements InterceptingMessageProcessor
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, process, receiveAsyncReply, sendAsyncRequest, setFailOnTimeout, setFlowConstruct, setReplySource, setStorePrefix, setTimeout, start, stop, toString |
ServiceAsyncRequestReplyRequestor
public ServiceAsyncRequestReplyRequestor()
postLatchAwait
protected void postLatchAwait(String asyncReplyCorrelationId)
throws MessagingException
- Overrides:
postLatchAwait
in class AbstractAsyncRequestReplyRequester
- Throws:
MessagingException
verifyReplyMessageSource
protected void verifyReplyMessageSource(MessageSource messageSource)
- Overrides:
verifyReplyMessageSource
in class AbstractAsyncRequestReplyRequester
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.