MultiConsumerJmsMessageReceiver
(set by default).@Deprecated public class JmsMessageReceiver extends AbstractMessageReceiver implements MessageListener
Modifier and Type | Class and Description |
---|---|
protected class |
JmsMessageReceiver.JmsWorker
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected JmsConnector |
connector
Deprecated.
|
protected MessageConsumer |
consumer
Deprecated.
|
protected RedeliveryHandler |
redeliveryHandler
Deprecated.
|
protected Session |
session
Deprecated.
|
protected boolean |
startOnConnect
Deprecated.
|
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
JmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
closeConsumer()
Deprecated.
|
protected void |
createConsumer()
Deprecated.
Create a consumer for the jms destination
|
protected void |
doConnect()
Deprecated.
|
protected void |
doDisconnect()
Deprecated.
|
protected void |
doDispose()
Deprecated.
|
protected void |
doStart()
Deprecated.
|
protected void |
doStop()
Deprecated.
|
void |
onMessage(Message message)
Deprecated.
|
boolean |
shouldConsumeInEveryNode()
Deprecated.
Determines whether to start or not the MessageSource base on the running node state.
|
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
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
protected JmsConnector connector
protected RedeliveryHandler redeliveryHandler
protected MessageConsumer consumer
protected Session session
protected boolean startOnConnect
public JmsMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
public void onMessage(Message message)
onMessage
in interface MessageListener
public boolean shouldConsumeInEveryNode()
AbstractMessageReceiver
shouldConsumeInEveryNode
in class AbstractMessageReceiver
protected void doStart() throws MuleException
doStart
in class AbstractTransportMessageHandler
MuleException
protected void doStop() throws MuleException
doStop
in class AbstractMessageReceiver
MuleException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void closeConsumer()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.