org.objectweb.joram.shared.client
Class XACnxRollback

java.lang.Object
  extended by org.objectweb.joram.shared.client.AbstractJmsMessage
      extended by org.objectweb.joram.shared.client.AbstractJmsRequest
          extended by org.objectweb.joram.shared.client.XACnxRollback
All Implemented Interfaces:
Streamable, java.io.Externalizable, java.io.Serializable

public final class XACnxRollback
extends AbstractJmsRequest

An XACnxRollback instance is used by an XAConnection for rolling back the operations performed during a transaction.

See Also:
Serialized Form

Field Summary
private  byte[] bq
          Transaction branch qualifier.
private  int fi
          Transaction identifier format.
private  byte[] gti
          Global transaction identifier.
private  java.util.Hashtable qDenyings
          Table holding the identifiers of the messages to deny on queues.
private static long serialVersionUID
          define serialVersionUID for interoperability
private  java.util.Hashtable subDenyings
          Table holding the identifiers of the messages to deny on subs.
 
Fields inherited from class org.objectweb.joram.shared.client.AbstractJmsRequest
requestId, target
 
Fields inherited from class org.objectweb.joram.shared.client.AbstractJmsMessage
ACTIVATE_CONSUMER_REQUEST, classid, classnames, CNX_CLOSE_REPLY, CNX_CLOSE_REQUEST, CNX_CONNECT_REPLY, CNX_CONNECT_REQUEST, CNX_START_REQUEST, CNX_STOP_REQUEST, COMMIT_REQUEST, CONSUMER_ACK_REQUEST, CONSUMER_CLOSE_SUB_REQUEST, CONSUMER_DENY_REQUEST, CONSUMER_MESSAGES, CONSUMER_RECEIVE_REQUEST, CONSUMER_SET_LIST_REQUEST, CONSUMER_SUB_REQUEST, CONSUMER_UNSET_LIST_REQUEST, CONSUMER_UNSUB_REQUEST, GET_ADMIN_TOPIC_REPLY, GET_ADMIN_TOPIC_REQUEST, JMS_REQUEST_GROUP, logger, MOM_EXCEPTION_REPLY, NULL_CLASS_ID, PING_REQUEST, PRODUCER_MESSAGES, QBROWSE_REPLY, QBROWSE_REQUEST, SERVER_REPLY, SESS_ACK_REQUEST, SESS_CREATE_DEST_REPLY, SESS_CREATE_DEST_REQUEST, SESS_DENY_REQUEST, TEMP_DEST_DELETE_REQUEST, XA_CNX_COMMIT, XA_CNX_PREPARE, XA_CNX_RECOVER_REPLY, XA_CNX_RECOVER_REQUEST, XA_CNX_ROLLBACK, XXX_SESS_CREATE_TTREQUEST
 
Constructor Summary
XACnxRollback()
          Constructs an XACnxRollback instance.
XACnxRollback(byte[] bq, int fi, byte[] gti)
          Constructs an XACnxRollback instance.
 
Method Summary
 void add(java.lang.String target, java.util.Vector ids, boolean queueMode)
          Adds a vector of denied messages' identifiers.
 byte[] getBQ()
          Returns the transaction branch qualifier.
protected  int getClassId()
           
 int getFI()
          Returns the transaction identifier format.
 byte[] getGTI()
          Returns the global transaction identifier.
 java.util.Vector getQueueIds(java.lang.String queue)
          Returns the vector of msg identifiers for a given queue.
 java.util.Enumeration getQueues()
          Returns the queues enumeration.
 java.util.Vector getSubIds(java.lang.String sub)
          Returns the vector of msg identifiers for a given subscription.
 java.util.Enumeration getSubs()
          Returns the subscriptions enumeration.
 void readFrom(java.io.InputStream is)
          The object implements the readFrom method to restore its contents from the input stream.
 void setBQ(byte[] bq)
           
 void setFI(int fi)
           
 void setGTI(byte[] gti)
           
 void setQDenyings(java.util.Hashtable qDenyings)
          Sets the queue denyings table.
 void setSubDenyings(java.util.Hashtable subDenyings)
          Sets the sub denyings table.
 void writeTo(java.io.OutputStream os)
          The object implements the writeTo method to write its contents to the output stream.
 
Methods inherited from class org.objectweb.joram.shared.client.AbstractJmsRequest
getRequestId, getTarget, setRequestId, setTarget, toString, toString
 
Methods inherited from class org.objectweb.joram.shared.client.AbstractJmsMessage
read, readExternal, soapCode, soapDecode, write, writeExternal
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

serialVersionUID

private static final long serialVersionUID
define serialVersionUID for interoperability

See Also:
Constant Field Values

bq

private byte[] bq
Transaction branch qualifier.


fi

private int fi
Transaction identifier format.


gti

private byte[] gti
Global transaction identifier.


qDenyings

private java.util.Hashtable qDenyings
Table holding the identifiers of the messages to deny on queues.


subDenyings

private java.util.Hashtable subDenyings
Table holding the identifiers of the messages to deny on subs.

Constructor Detail

XACnxRollback

public XACnxRollback(byte[] bq,
                     int fi,
                     byte[] gti)
Constructs an XACnxRollback instance.

Parameters:
bq - Transaction branch qualifier.
fi - Transaction identifier format.
gti - Global transaction identifier.

XACnxRollback

public XACnxRollback()
Constructs an XACnxRollback instance.

Method Detail

setBQ

public void setBQ(byte[] bq)

getBQ

public byte[] getBQ()
Returns the transaction branch qualifier.


setFI

public void setFI(int fi)

getFI

public int getFI()
Returns the transaction identifier format.


setGTI

public void setGTI(byte[] gti)

getGTI

public byte[] getGTI()
Returns the global transaction identifier.


add

public void add(java.lang.String target,
                java.util.Vector ids,
                boolean queueMode)
Adds a vector of denied messages' identifiers.

Parameters:
target - Name of the queue or of the subscription where denying the messages.
ids - Vector of message identifiers.
queueMode - true if the messages have to be denied on a queue.

getQueues

public java.util.Enumeration getQueues()
Returns the queues enumeration.


getQueueIds

public java.util.Vector getQueueIds(java.lang.String queue)
Returns the vector of msg identifiers for a given queue.


getSubs

public java.util.Enumeration getSubs()
Returns the subscriptions enumeration.


setQDenyings

public void setQDenyings(java.util.Hashtable qDenyings)
Sets the queue denyings table.


setSubDenyings

public void setSubDenyings(java.util.Hashtable subDenyings)
Sets the sub denyings table.


getSubIds

public java.util.Vector getSubIds(java.lang.String sub)
Returns the vector of msg identifiers for a given subscription.


getClassId

protected int getClassId()
Specified by:
getClassId in class AbstractJmsMessage

writeTo

public void writeTo(java.io.OutputStream os)
             throws java.io.IOException
The object implements the writeTo method to write its contents to the output stream.

Specified by:
writeTo in interface Streamable
Overrides:
writeTo in class AbstractJmsRequest
Parameters:
os - the stream to write the object to
Throws:
java.io.IOException

readFrom

public void readFrom(java.io.InputStream is)
              throws java.io.IOException
The object implements the readFrom method to restore its contents from the input stream.

Specified by:
readFrom in interface Streamable
Overrides:
readFrom in class AbstractJmsRequest
Parameters:
is - the stream to read data from in order to restore the object
Throws:
java.io.IOException


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.