org.codehaus.activemq.ra
Class ActiveMQRASession

java.lang.Object
  extended byorg.codehaus.activemq.ActiveMQSession
      extended byorg.codehaus.activemq.ActiveMQXASession
          extended byorg.codehaus.activemq.ra.ActiveMQRASession
All Implemented Interfaces:
org.codehaus.activemq.ActiveMQMessageDispatcher, org.codehaus.activemq.Closeable, org.codehaus.activemq.message.MessageAcknowledge, QueueSession, Runnable, Session, org.codehaus.activemq.management.StatsCapable, TopicSession, XAQueueSession, XAResource, XASession, XATopicSession

public class ActiveMQRASession
extends org.codehaus.activemq.ActiveMQXASession
implements org.codehaus.activemq.Closeable

The ActiveMQRASession extends the ActiveMQXASession so that it is more flexible in terms of using the availble transaction context. A normal ActiveMQXASession implements the XASession interface stictly which means that it can only do work in the context of an XA transaction.

Version:
$Revision: 1.1.2.1 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.ActiveMQSession
acknowledgeMode, closed, connection, CONSUMER_DISPATCH_ASYNC, CONSUMER_DISPATCH_SYNC, CONSUMER_DISPATCH_UNSET, consumers, currentTransactionId, packetIdGenerator, producers
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Fields inherited from interface javax.transaction.xa.XAResource
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
 
Constructor Summary
ActiveMQRASession(org.codehaus.activemq.ActiveMQXAConnection theConnection, int theAcknowlegeMode)
           
 
Method Summary
 void begin()
          Used to know when a local transaction has started.
 void commit()
           
protected  void doStartTransaction()
           
 void end(Xid xid, int flags)
           
 boolean getTransacted()
           
 boolean isAutoCommit()
           
 boolean isInLocalTransaction()
           
protected  boolean isXaTransacted()
           
protected  void postDeliveryHook(MessageListener listener, org.codehaus.activemq.message.ActiveMQMessage message)
           
protected  void preDeliveryHook(MessageListener listener, org.codehaus.activemq.message.ActiveMQMessage message)
           
 void rollback()
           
 void setAcknowlegeMode(int acknowledgeMode)
          Allows you to change the acknowlegeMode of an existing session.
 void setAutoCommit(boolean autoCommit)
           
 void start(Xid xid, int flags)
           
 
Methods inherited from class org.codehaus.activemq.ActiveMQXASession
checkClosedXA, close, commit, forget, getQueueSession, getSession, getTopicSession, getTransactionTimeout, getXAResource, isSameRM, prepare, recover, rollback, setTransactionTimeout
 
Methods inherited from class org.codehaus.activemq.ActiveMQSession
acknowledge, addConsumer, addProducer, afterMessageDelivered, beforeMessageDelivered, checkClosed, clearMessagesInProgress, commitLocalTransaction, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createConsumerInfo, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createProducerInfo, createPublisher, createQueue, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, dispatch, doAcknowledge, doClose, getAcknowledgeMode, getLocalTransactionEventListener, getMessageListener, getSessionId, getSessionStats, getStartTime, getStats, isClientAcknowledge, isTarget, isTransacted, recover, redeliverUnacknowledgedMessages, redeliverUnacknowledgedMessages, removeConsumer, removeProducer, rollbackLocalTransaction, run, send, setLocalTransactionEventListener, setMessageListener, setSessionConsumerDispatchState, setSessionId, setStartTime, start, startLocalTransaction, stop, unsubscribe
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.codehaus.activemq.Closeable
close
 
Methods inherited from interface javax.jms.QueueSession
createBrowser, createBrowser, createQueue, createReceiver, createReceiver, createSender, createTemporaryQueue
 
Methods inherited from interface javax.jms.Session
createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener, unsubscribe
 
Methods inherited from interface javax.jms.TopicSession
createDurableSubscriber, createDurableSubscriber, createPublisher, createSubscriber, createSubscriber, createTemporaryTopic, createTopic, unsubscribe
 

Constructor Detail

ActiveMQRASession

public ActiveMQRASession(org.codehaus.activemq.ActiveMQXAConnection theConnection,
                         int theAcknowlegeMode)
                  throws JMSException
Method Detail

getTransacted

public boolean getTransacted()
                      throws JMSException
Specified by:
getTransacted in interface Session
Throws:
JMSException

isXaTransacted

protected boolean isXaTransacted()

doStartTransaction

protected void doStartTransaction()
                           throws JMSException
Throws:
JMSException - if some internal error occurs

begin

public void begin()
           throws JMSException
Used to know when a local transaction has started.

Throws:
JMSException

isInLocalTransaction

public boolean isInLocalTransaction()

rollback

public void rollback()
              throws JMSException
Specified by:
rollback in interface Session
Throws:
JMSException

commit

public void commit()
            throws JMSException
Specified by:
commit in interface Session
Throws:
JMSException

start

public void start(Xid xid,
                  int flags)
           throws XAException
Specified by:
start in interface XAResource
Throws:
XAException

end

public void end(Xid xid,
                int flags)
         throws XAException
Specified by:
end in interface XAResource
Throws:
XAException

isAutoCommit

public boolean isAutoCommit()
Returns:
Returns the autoCommit.

setAutoCommit

public void setAutoCommit(boolean autoCommit)
Parameters:
autoCommit - The autoCommit to set.

setAcknowlegeMode

public void setAcknowlegeMode(int acknowledgeMode)
Allows you to change the acknowlegeMode of an existing session.

Parameters:
acknowledgeMode -

preDeliveryHook

protected void preDeliveryHook(MessageListener listener,
                               org.codehaus.activemq.message.ActiveMQMessage message)

postDeliveryHook

protected void postDeliveryHook(MessageListener listener,
                                org.codehaus.activemq.message.ActiveMQMessage message)


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.