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

java.lang.Object
  extended by 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)


Copyright © 2006 JBoss Inc. All Rights Reserved.