public class WebsphereTransactedJmsMessageReceiver extends XaTransactedJmsMessageReceiver
XaTransactedJmsMessageReceiver.JmsThreadContext, XaTransactedJmsMessageReceiver.ThreadContextLocal
TransactedPollingMessageReceiver.MessageProcessorWorker
connector, context, DEFAULT_JMS_POLL_FREQUENCY, DEFAULT_JMS_POLL_TIMEUNIT, redeliveryHandler, reuseConsumer, reuseSession, timeout
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
connected, connecting, connectionStrategy, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
WebsphereTransactedJmsMessageReceiver(Connector umoConnector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
closeResource, createConsumer, doDisconnect, doDispose, getMessages, poll, processMessage
doStart, isReceiveMessagesInTransaction, isUseMultipleTransactedReceivers, setReceiveMessagesInTransaction, setUseMultipleTransactedReceivers
createWork, doStop, getFrequency, getTimeUnit, schedule, setFrequency, setTimeUnit, unschedule
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
public WebsphereTransactedJmsMessageReceiver(Connector umoConnector, Service service, InboundEndpoint endpoint) throws InitialisationException, CreateException
protected void doConnect() throws Exception
doConnect
in class XaTransactedJmsMessageReceiver
Exception
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.