|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.ActiveMQSession
org.codehaus.activemq.ActiveMQXASession
org.codehaus.activemq.ra.ActiveMQRASession
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.
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.TopicSession |
createDurableSubscriber, createDurableSubscriber, createPublisher, createSubscriber, createSubscriber, createTemporaryTopic, createTopic, unsubscribe |
Constructor Detail |
public ActiveMQRASession(org.codehaus.activemq.ActiveMQXAConnection theConnection, int theAcknowlegeMode) throws JMSException
Method Detail |
public boolean getTransacted() throws JMSException
getTransacted
in interface Session
JMSException
protected boolean isXaTransacted()
protected void doStartTransaction() throws JMSException
JMSException
- if some internal error occurspublic void begin() throws JMSException
JMSException
public boolean isInLocalTransaction()
public void rollback() throws JMSException
rollback
in interface Session
JMSException
public void commit() throws JMSException
commit
in interface Session
JMSException
public void start(Xid xid, int flags) throws XAException
start
in interface XAResource
XAException
public void end(Xid xid, int flags) throws XAException
end
in interface XAResource
XAException
public boolean isAutoCommit()
public void setAutoCommit(boolean autoCommit)
autoCommit
- The autoCommit to set.public void setAcknowlegeMode(int acknowledgeMode)
acknowledgeMode
- protected void preDeliveryHook(MessageListener listener, org.codehaus.activemq.message.ActiveMQMessage message)
protected void postDeliveryHook(MessageListener listener, org.codehaus.activemq.message.ActiveMQMessage message)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |