org.mule.service
Class ServiceAsyncReplyCompositeMessageSource
java.lang.Object
org.mule.source.StartableCompositeMessageSource
org.mule.service.ServiceCompositeMessageSource
org.mule.service.ServiceAsyncReplyCompositeMessageSource
- All Implemented Interfaces:
- FlowConstructAware, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, RouterStatisticsRecorder, CompositeMessageSource, MessageSource
public class ServiceAsyncReplyCompositeMessageSource
- extends ServiceCompositeMessageSource
Extension of StartableCompositeMessageSource
which adds message processors between the composite
source and the target listener
Methods inherited from class org.mule.service.ServiceCompositeMessageSource |
addMessageProcessor, addSource, dispose, getCatchAllStrategy, getEndpoint, getEndpoints, getMessageProcessors, getRouterStatistics, initialise, removeSource, setCatchAllStrategy, setMessageProcessors, setMessageSources, setRouterStatistics, start, stop |
timeout
protected Long timeout
failOnTimeout
protected boolean failOnTimeout
ServiceAsyncReplyCompositeMessageSource
public ServiceAsyncReplyCompositeMessageSource()
createMessageProcessorChain
protected void createMessageProcessorChain()
throws MuleException
- Overrides:
createMessageProcessorChain
in class ServiceCompositeMessageSource
- Throws:
MuleException
getTimeout
public Long getTimeout()
setTimeout
public void setTimeout(Long timeout)
isFailOnTimeout
public boolean isFailOnTimeout()
setFailOnTimeout
public void setFailOnTimeout(boolean failOnTimeout)
expireAggregation
public void expireAggregation(String groupId)
throws MessagingException
- Throws:
MessagingException
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.