org.jboss.messaging.core.transaction.impl
Class TransactionImpl

java.lang.Object
  org.jboss.messaging.core.transaction.impl.TransactionImpl

All Implemented Interfaces:

Transaction

public class TransactionImpl
extends java.lang.Object
implements Transaction

A TransactionImpl

Author:

Tim Fox

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.messaging.core.transaction.Transaction

Transaction.State

Constructor Summary

TransactionImpl(StorageManager storageManager, PostOffice postOffice)

TransactionImpl(javax.transaction.xa.Xid xid, StorageManager storageManager, PostOffice postOffice)

Method Summary

void	addAcknowledgement(MessageReference acknowledgement)
void	addMessage(ServerMessage message)
void	commit()
int	getAcknowledgementsCount()
long	getID()
Transaction.State	getState()
javax.transaction.xa.Xid	getXid()
boolean	isContainsPersistent()
boolean	isEmpty()
void	markAsRollbackOnly(MessagingException messagingException)
void	prepare()
void	resume()
void	rollback(HierarchicalRepository<QueueSettings> queueSettingsRepository)
void	setContainsPersistent(boolean containsPersistent)
void	suspend()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionImpl

public TransactionImpl(StorageManager storageManager,
                       PostOffice postOffice)

TransactionImpl

public TransactionImpl(javax.transaction.xa.Xid xid,
                       StorageManager storageManager,
                       PostOffice postOffice)

Method Detail

getID

public long getID()

Specified by:

getID in interface Transaction

addMessage

public void addMessage(ServerMessage message)
                throws java.lang.Exception

Specified by:

addMessage in interface Transaction

Throws:

java.lang.Exception

addAcknowledgement

public void addAcknowledgement(MessageReference acknowledgement)
                        throws java.lang.Exception

Specified by:

addAcknowledgement in interface Transaction

Throws:

java.lang.Exception

prepare

public void prepare()
             throws java.lang.Exception

Specified by:

prepare in interface Transaction

Throws:

java.lang.Exception

commit

public void commit()
            throws java.lang.Exception

Specified by:

commit in interface Transaction

Throws:

java.lang.Exception

rollback

public void rollback(HierarchicalRepository<QueueSettings> queueSettingsRepository)
              throws java.lang.Exception

Specified by:

rollback in interface Transaction

Throws:

java.lang.Exception

getAcknowledgementsCount

public int getAcknowledgementsCount()

Specified by:

getAcknowledgementsCount in interface Transaction

suspend

public void suspend()

Specified by:

suspend in interface Transaction

resume

public void resume()

Specified by:

resume in interface Transaction

getState

public Transaction.State getState()

Specified by:

getState in interface Transaction

getXid

public javax.transaction.xa.Xid getXid()

Specified by:

getXid in interface Transaction

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Transaction

isContainsPersistent

public boolean isContainsPersistent()

Specified by:

isContainsPersistent in interface Transaction

markAsRollbackOnly

public void markAsRollbackOnly(MessagingException messagingException)

Specified by:

markAsRollbackOnly in interface Transaction

setContainsPersistent

public void setContainsPersistent(boolean containsPersistent)