public class TransactedSingleResourceJmsMessageReceiver extends AbstractMessageReceiver implements javax.jms.MessageListener
Modifier and Type | Class and Description |
---|---|
protected class |
TransactedSingleResourceJmsMessageReceiver.MessageReceiverWorker |
Modifier and Type | Field and Description |
---|---|
protected JmsConnector |
connector |
protected javax.jms.MessageConsumer |
consumer |
protected boolean |
receiveMessagesInTransaction
determines whether messages will be received in a transaction template
|
protected RedeliveryHandler |
redeliveryHandler |
protected javax.jms.Session |
session |
protected boolean |
startOnConnect |
protected boolean |
useMultipleReceivers
determines whether Multiple receivers are created to improve throughput
|
connected, connecting, connectionStrategy, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
TransactedSingleResourceJmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConsumer() |
protected void |
doConnect() |
void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doStart() |
protected void |
doStop() |
void |
onMessage(javax.jms.Message message) |
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 JmsConnector connector
protected RedeliveryHandler redeliveryHandler
protected javax.jms.MessageConsumer consumer
protected javax.jms.Session session
protected boolean startOnConnect
protected boolean receiveMessagesInTransaction
protected boolean useMultipleReceivers
public TransactedSingleResourceJmsMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint) throws CreateException
connector
- service
- endpoint
- InitialisationException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws Exception
doConnect
in class AbstractMessageReceiver
Exception
protected void doStart() throws MuleException
doStart
in class AbstractMessageReceiver
MuleException
protected void doStop() throws MuleException
doStop
in class AbstractMessageReceiver
MuleException
public void doDisconnect() throws Exception
doDisconnect
in class AbstractMessageReceiver
Exception
protected void closeConsumer()
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.