org.mule.transport.jms
Class MultiConsumerJmsMessageReceiver
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageReceiver
org.mule.transport.jms.MultiConsumerJmsMessageReceiver
- All Implemented Interfaces:
- Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, MessageSource, Connectable, MessageReceiver
public class MultiConsumerJmsMessageReceiver
- extends AbstractMessageReceiver
In Mule an endpoint corresponds to a single receiver. It's up to the receiver to do multithreaded consumption and
resource allocation, if needed. This class honors the numberOfConcurrentTransactedReceivers
strictly
and will create exactly this number of consumers.
Field Summary |
protected List<org.mule.transport.jms.MultiConsumerJmsMessageReceiver.SubReceiver> |
consumers
|
protected int |
receiversCount
|
Methods inherited from class org.mule.transport.AbstractMessageReceiver |
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, toString, warnIfMuleClientSendUsed |
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
consumers
protected final List<org.mule.transport.jms.MultiConsumerJmsMessageReceiver.SubReceiver> consumers
receiversCount
protected final int receiversCount
MultiConsumerJmsMessageReceiver
public MultiConsumerJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
throws CreateException
- Throws:
CreateException
doStart
protected void doStart()
throws MuleException
- Overrides:
doStart
in class AbstractTransportMessageHandler
- Throws:
MuleException
doStop
protected void doStop()
throws MuleException
- Overrides:
doStop
in class AbstractMessageReceiver
- Throws:
MuleException
doConnect
protected void doConnect()
throws Exception
- Overrides:
doConnect
in class AbstractTransportMessageHandler
- Throws:
Exception
doDisconnect
protected void doDisconnect()
throws Exception
- Overrides:
doDisconnect
in class AbstractTransportMessageHandler
- Throws:
Exception
doDispose
protected void doDispose()
- Overrides:
doDispose
in class AbstractMessageReceiver
startSubReceivers
protected void startSubReceivers()
throws MuleException
- Throws:
MuleException
shouldConsumeInEveryNode
public boolean shouldConsumeInEveryNode()
- Description copied from class:
AbstractMessageReceiver
- Determines whether to start or not the MessageSource base on the running node state.
- Overrides:
shouldConsumeInEveryNode
in class AbstractMessageReceiver
- Returns:
- false if this MessageSource should be stated only in the primary node, true if it should be started in every node.
Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.