public class MultiConsumerJmsMessageReceiver extends AbstractMessageReceiver
transacted.message.receiver
(it may work with non-transacted sessions as well,
just hasn't been tested and load-tested yet.
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.Modifier and Type | Class and Description |
---|---|
protected class |
MultiConsumerJmsMessageReceiver.JmsWorker |
Modifier and Type | Field and Description |
---|---|
protected BlockingDeque |
consumers |
protected int |
receiversCount |
connected, connecting, connectionStrategy, connector, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
MultiConsumerJmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doStart() |
protected void |
doStop() |
connect, disconnect, dispose, doInitialise, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getReceiverKey, getService, getWorkManager, handleException, handleUnacceptedFilter, initialise, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setConnector, setEndpoint, setExceptionDetails, setListener, setReceiverKey, setService, setWorkManager, start, stop, toString
protected final BlockingDeque consumers
protected volatile int receiversCount
public MultiConsumerJmsMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doStart() throws MuleException
doStart
in class AbstractMessageReceiver
MuleException
protected void doStop() throws MuleException
doStop
in class AbstractMessageReceiver
MuleException
protected void doConnect() throws Exception
doConnect
in class AbstractMessageReceiver
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractMessageReceiver
Exception
protected void doDispose()
doDispose
in class AbstractMessageReceiver
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.