org.jboss.jms.tx
Class ClientTransaction

java.lang.Object
  extended by org.jboss.jms.tx.ClientTransaction

public class ClientTransaction
extends java.lang.Object

Holds the state of a transaction on the client side

Author:
Nested Class Summary
 class ClientTransaction.SessionTxState
           
 
Field Summary
static byte TX_COMMITED
           
static byte TX_ENDED
           
static byte TX_OPEN
           
static byte TX_PREPARED
           
static byte TX_ROLLEDBACK
           
 
Constructor Summary
ClientTransaction()
           
 
Method Summary
 void addAck(java.lang.String sessionId, DeliveryInfo info)
           
 void addMessage(java.lang.String sessionId, JBossMessage msg)
           
 void clearMessages()
           
 java.util.List getDeliveriesForSession(java.lang.String sessionID)
          May return an empty list, but never null.
 java.util.List getSessionStates()
           
 byte getState()
           
 void handleFailover(int newServerID, java.lang.String oldSessionID, java.lang.String newSessionID)
           
 boolean hasPersistentAcks()
           
 boolean isFailedOver()
           
 void read(java.io.DataInputStream in)
           
 void setState(byte state)
           
 void write(java.io.DataOutputStream out)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TX_OPEN

public static final byte TX_OPEN
See Also:
Constant Field Values

TX_ENDED

public static final byte TX_ENDED
See Also:
Constant Field Values

TX_PREPARED

public static final byte TX_PREPARED
See Also:
Constant Field Values

TX_COMMITED

public static final byte TX_COMMITED
See Also:
Constant Field Values

TX_ROLLEDBACK

public static final byte TX_ROLLEDBACK
See Also:
Constant Field Values
Constructor Detail

ClientTransaction

public ClientTransaction()
Method Detail

getState

public byte getState()

addMessage

public void addMessage(java.lang.String sessionId,
                       JBossMessage msg)

addAck

public void addAck(java.lang.String sessionId,
                   DeliveryInfo info)

hasPersistentAcks

public boolean hasPersistentAcks()

isFailedOver

public boolean isFailedOver()

clearMessages

public void clearMessages()

setState

public void setState(byte state)

getSessionStates

public java.util.List getSessionStates()

handleFailover

public void handleFailover(int newServerID,
                           java.lang.String oldSessionID,
                           java.lang.String newSessionID)

getDeliveriesForSession

public java.util.List getDeliveriesForSession(java.lang.String sessionID)
May return an empty list, but never null.


write

public void write(java.io.DataOutputStream out)
           throws java.lang.Exception
Throws:
java.lang.Exception

read

public void read(java.io.DataInputStream in)
          throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.