org.mule.transport.amqp.internal.endpoint.receiver
Class MultiChannelMessageSubReceiver
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageReceiver
org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
- All Implemented Interfaces:
- org.mule.api.lifecycle.Disposable, org.mule.api.lifecycle.Initialisable, org.mule.api.lifecycle.Lifecycle, org.mule.api.lifecycle.LifecycleStateEnabled, org.mule.api.lifecycle.Startable, org.mule.api.lifecycle.Stoppable, org.mule.api.source.MessageSource, org.mule.api.transport.Connectable, org.mule.api.transport.MessageReceiver
public class MultiChannelMessageSubReceiver
- extends org.mule.transport.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.
Fields inherited from class org.mule.transport.AbstractMessageReceiver |
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler |
Fields inherited from class org.mule.transport.AbstractTransportMessageHandler |
connected, connector, lifecycleManager, logger, muleMessageFactory, retryTemplate |
Fields inherited from interface org.mule.api.lifecycle.Initialisable |
PHASE_NAME |
Fields inherited from interface org.mule.api.lifecycle.Startable |
PHASE_NAME |
Fields inherited from interface org.mule.api.lifecycle.Stoppable |
PHASE_NAME |
Fields inherited from interface org.mule.api.lifecycle.Disposable |
PHASE_NAME |
Methods inherited from class org.mule.transport.AbstractMessageReceiver |
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doDispose, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed |
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doConnect, doDisconnect, 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.transport.MessageReceiver |
createMuleMessage, createMuleMessage |
Methods inherited from interface org.mule.api.transport.Connectable |
connect, disconnect, isConnected, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
Methods inherited from interface org.mule.api.lifecycle.Disposable |
dispose |
CONSUMER_TAG
public static final String CONSUMER_TAG
- See Also:
- Constant Field Values
parentReceiver
protected final MultiChannelMessageReceiver parentReceiver
amqpConnector
protected final AmqpConnector amqpConnector
endpoint
protected final org.mule.api.endpoint.ImmutableEndpoint endpoint
endpointUtil
protected final AmqpEndpointUtil endpointUtil
consumerTag
protected volatile String consumerTag
channel
protected com.rabbitmq.client.Channel channel
queueName
protected String queueName
MultiChannelMessageSubReceiver
public MultiChannelMessageSubReceiver(MultiChannelMessageReceiver parentReceiver)
throws org.mule.api.lifecycle.CreateException
- Throws:
org.mule.api.lifecycle.CreateException
doStart
public void doStart()
throws org.mule.api.MuleException
- Overrides:
doStart
in class org.mule.transport.AbstractTransportMessageHandler
- Throws:
org.mule.api.MuleException
doStop
public void doStop()
- Overrides:
doStop
in class org.mule.transport.AbstractTransportMessageHandler
restart
protected void restart(boolean cancelSubscription)
getChannel
public com.rabbitmq.client.Channel getChannel()
getQueueName
protected String getQueueName()
getClientConsumerTag
protected String getClientConsumerTag()
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.