@Deprecated public class ServiceCompositeMessageSource extends StartableCompositeMessageSource implements Initialisable, RouterStatisticsRecorder
StartableCompositeMessageSource
which adds message processors between the composite
source and the target listenerModifier and Type | Field and Description |
---|---|
protected MessageProcessor |
catchAllStrategy
Deprecated.
|
protected List<InboundEndpoint> |
endpoints
Deprecated.
|
protected List<MessageProcessor> |
processors
Deprecated.
|
protected RouterStatistics |
statistics
Deprecated.
|
flowConstruct, initialised, listener, log, muleContext, sources, started, starting
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
ServiceCompositeMessageSource()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
addMessageProcessor(MessageProcessor processor)
Deprecated.
|
void |
addSource(MessageSource source)
Deprecated.
|
protected void |
createMessageProcessorChain()
Deprecated.
|
void |
dispose()
Deprecated.
A lifecycle method where implementor should free up any resources.
|
MessageProcessor |
getCatchAllStrategy()
Deprecated.
|
InboundEndpoint |
getEndpoint(String name)
Deprecated.
|
List<InboundEndpoint> |
getEndpoints()
Deprecated.
|
List<MessageProcessor> |
getMessageProcessors()
Deprecated.
|
RouterStatistics |
getRouterStatistics()
Deprecated.
|
void |
initialise()
Deprecated.
Method used to perform any initialisation work.
|
void |
removeSource(MessageSource source)
Deprecated.
|
void |
setCatchAllStrategy(MessageProcessor catchAllStrategy)
Deprecated.
|
void |
setMessageProcessors(List<MessageProcessor> processors)
Deprecated.
|
void |
setMessageSources(List<MessageSource> sources)
Deprecated.
|
void |
setRouterStatistics(RouterStatistics statistics)
Deprecated.
|
void |
start()
Deprecated.
|
void |
stop()
Deprecated.
|
getSources, setFlowConstruct, setListener, setMuleContext, toString
protected List<MessageProcessor> processors
protected RouterStatistics statistics
protected List<InboundEndpoint> endpoints
protected MessageProcessor catchAllStrategy
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
initialise
in class StartableCompositeMessageSource
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic void dispose()
Disposable
dispose
in interface Disposable
dispose
in class StartableCompositeMessageSource
protected void createMessageProcessorChain() throws MuleException
MuleException
public void start() throws MuleException
start
in interface Startable
start
in class StartableCompositeMessageSource
MuleException
public void stop() throws MuleException
stop
in interface Stoppable
stop
in class StartableCompositeMessageSource
MuleException
public void setMessageProcessors(List<MessageProcessor> processors)
public void addMessageProcessor(MessageProcessor processor)
public void addSource(MessageSource source) throws MuleException
addSource
in interface CompositeMessageSource
addSource
in class StartableCompositeMessageSource
MuleException
public void removeSource(MessageSource source) throws MuleException
removeSource
in interface CompositeMessageSource
removeSource
in class StartableCompositeMessageSource
MuleException
public void setMessageSources(List<MessageSource> sources) throws MuleException
setMessageSources
in class StartableCompositeMessageSource
MuleException
public List<InboundEndpoint> getEndpoints()
public List<MessageProcessor> getMessageProcessors()
public RouterStatistics getRouterStatistics()
public void setRouterStatistics(RouterStatistics statistics)
setRouterStatistics
in interface RouterStatisticsRecorder
public InboundEndpoint getEndpoint(String name)
public void setCatchAllStrategy(MessageProcessor catchAllStrategy)
public MessageProcessor getCatchAllStrategy()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.