org.mule.transport.jms
Class XaTransactedJmsMessageReceiver

java.lang.Object
  extended by org.mule.transport.AbstractTransportMessageHandler
      extended by org.mule.transport.AbstractMessageReceiver
          extended by org.mule.transport.AbstractPollingMessageReceiver
              extended by org.mule.transport.TransactedPollingMessageReceiver
                  extended by org.mule.transport.jms.XaTransactedJmsMessageReceiver
All Implemented Interfaces:
Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, MessageSource, Connectable, MessageReceiver
Direct Known Subclasses:
WebsphereTransactedJmsMessageReceiver

public class XaTransactedJmsMessageReceiver
extends TransactedPollingMessageReceiver


Nested Class Summary
protected static class XaTransactedJmsMessageReceiver.JmsThreadContext
          Holder receiving the session and consumer for this thread.
protected static class XaTransactedJmsMessageReceiver.ThreadContextLocal
          Strongly typed ThreadLocal for ThreadContext.
 
Nested classes/interfaces inherited from class org.mule.transport.TransactedPollingMessageReceiver
TransactedPollingMessageReceiver.MessageProcessorWorker
 
Field Summary
protected  JmsConnector connector
           
protected  XaTransactedJmsMessageReceiver.ThreadContextLocal context
           
static long DEFAULT_JMS_POLL_FREQUENCY
           
static TimeUnit DEFAULT_JMS_POLL_TIMEUNIT
           
protected  boolean reuseConsumer
           
protected  boolean reuseSession
           
protected  long timeout
           
 
Fields inherited from class org.mule.transport.AbstractPollingMessageReceiver
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
 
Fields inherited from class org.mule.transport.AbstractMessageReceiver
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
 
Fields inherited from class org.mule.transport.AbstractTransportMessageHandler
connected, endpoint, 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
 
Constructor Summary
XaTransactedJmsMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint)
           
 
Method Summary
protected  void closeResource(boolean force)
          Close Sesison and consumer
protected  MessageConsumer createConsumer()
          Create a consumer for the jms destination
protected  void doConnect()
           
protected  void doDisconnect()
           
protected  void doDispose()
           
protected  List<MuleMessage> getMessages()
           
 void poll()
          The poll method is overriden from the TransactedPollingMessageReceiver
protected  void processMessage(Object msg)
           
 boolean shouldConsumeInEveryNode()
          Determines whether to start or not the MessageSource base on the running node state.
 
Methods inherited from class org.mule.transport.TransactedPollingMessageReceiver
doStart, hasNoMessages, isReceiveMessagesInTransaction, isUseMultipleTransactedReceivers, setReceiveMessagesInTransaction, setUseMultipleTransactedReceivers
 
Methods inherited from class org.mule.transport.AbstractPollingMessageReceiver
createWork, disableNativeScheduling, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule
 
Methods inherited from class org.mule.transport.AbstractMessageReceiver
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
 
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
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
 

Field Detail

DEFAULT_JMS_POLL_FREQUENCY

public static final long DEFAULT_JMS_POLL_FREQUENCY
See Also:
Constant Field Values

DEFAULT_JMS_POLL_TIMEUNIT

public static final TimeUnit DEFAULT_JMS_POLL_TIMEUNIT

connector

protected final JmsConnector connector

reuseConsumer

protected boolean reuseConsumer

reuseSession

protected boolean reuseSession

context

protected final XaTransactedJmsMessageReceiver.ThreadContextLocal context

timeout

protected final long timeout
Constructor Detail

XaTransactedJmsMessageReceiver

public XaTransactedJmsMessageReceiver(Connector connector,
                                      FlowConstruct flowConstruct,
                                      InboundEndpoint endpoint)
                               throws CreateException
Throws:
CreateException
Method Detail

shouldConsumeInEveryNode

public boolean shouldConsumeInEveryNode()
Description copied from class: AbstractMessageReceiver
Determines whether to start or not the MessageSource base on the running node state.

Overrides:
shouldConsumeInEveryNode in class AbstractMessageReceiver
Returns:
false if this MessageSource should be stated only in the primary node, true if it should be started in every node.

doDispose

protected void doDispose()
Overrides:
doDispose in class AbstractMessageReceiver

doConnect

protected void doConnect()
                  throws Exception
Overrides:
doConnect in class AbstractTransportMessageHandler
Throws:
Exception

doDisconnect

protected void doDisconnect()
                     throws Exception
Overrides:
doDisconnect in class AbstractTransportMessageHandler
Throws:
Exception

poll

public void poll()
          throws Exception
The poll method is overriden from the TransactedPollingMessageReceiver

Overrides:
poll in class TransactedPollingMessageReceiver
Throws:
Exception

getMessages

protected List<MuleMessage> getMessages()
                                 throws Exception
Specified by:
getMessages in class TransactedPollingMessageReceiver
Throws:
Exception

processMessage

protected void processMessage(Object msg)
                       throws Exception
Specified by:
processMessage in class TransactedPollingMessageReceiver
Throws:
Exception

closeResource

protected void closeResource(boolean force)
Close Sesison and consumer


createConsumer

protected MessageConsumer createConsumer()
                                  throws Exception
Create a consumer for the jms destination

Throws:
Exception


Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.