public class WebsphereTransactedJmsMessageReceiver extends XaTransactedJmsMessageReceiver
XaTransactedJmsMessageReceiver.JmsThreadContext, XaTransactedJmsMessageReceiver.ThreadContextLocal
TransactedPollingMessageReceiver.MessageProcessorWorker
connector, context, DEFAULT_JMS_POLL_FREQUENCY, DEFAULT_JMS_POLL_TIMEUNIT, reuseConsumer, reuseSession, timeout
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
WebsphereTransactedJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
closeResource, createConsumer, doDisconnect, doDispose, getMessages, poll, processMessage, shouldConsumeInEveryNode
doStart, hasNoMessages, isReceiveMessagesInTransaction, isUseMultipleTransactedReceivers, setReceiveMessagesInTransaction, setUseMultipleTransactedReceivers
createWork, disableNativeScheduling, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule
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
public WebsphereTransactedJmsMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws InitialisationException, CreateException
protected void doConnect() throws Exception
doConnect
in class XaTransactedJmsMessageReceiver
Exception
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.