public final class XACnxRollback extends AbstractJmsRequest
XACnxRollback
instance is used by an
XAConnection
for rolling back the operations performed
during a transaction.Modifier and Type | Field and Description |
---|---|
private byte[] |
bq
Transaction branch qualifier.
|
private int |
fi
Transaction identifier format.
|
private byte[] |
gti
Global transaction identifier.
|
private Hashtable |
qDenyings
Table holding the identifiers of the messages to deny on queues.
|
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
private Hashtable |
subDenyings
Table holding the identifiers of the messages to deny on subs.
|
requestId, target
ACTIVATE_CONSUMER_REQUEST, ADD_CLIENTID_REPLY, ADD_CLIENTID_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
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
XACnxRollback()
Constructs an
XACnxRollback instance. |
XACnxRollback(byte[] bq,
int fi,
byte[] gti)
Constructs an
XACnxRollback instance. |
Modifier and Type | Method and Description |
---|---|
void |
add(String target,
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.
|
Vector |
getQueueIds(String queue)
Returns the vector of msg identifiers for a given queue.
|
Enumeration |
getQueues()
Returns the queues enumeration.
|
Vector |
getSubIds(String sub)
Returns the vector of msg identifiers for a given subscription.
|
Enumeration |
getSubs()
Returns the subscriptions enumeration.
|
void |
readFrom(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(Hashtable qDenyings)
Sets the queue denyings table.
|
void |
setSubDenyings(Hashtable subDenyings)
Sets the sub denyings table.
|
void |
writeTo(OutputStream os)
The object implements the writeTo method to write its contents to
the output stream.
|
decode, encode, getEncodableClassId, getEncodedSize, getRequestId, getTarget, setRequestId, setTarget, toString, toString
read, readExternal, write, writeExternal
private static final long serialVersionUID
private byte[] bq
private int fi
private byte[] gti
private Hashtable qDenyings
private Hashtable subDenyings
public XACnxRollback(byte[] bq, int fi, byte[] gti)
XACnxRollback
instance.bq
- Transaction branch qualifier.fi
- Transaction identifier format.gti
- Global transaction identifier.public XACnxRollback()
XACnxRollback
instance.public void setBQ(byte[] bq)
public byte[] getBQ()
public void setFI(int fi)
public int getFI()
public void setGTI(byte[] gti)
public byte[] getGTI()
public void add(String target, Vector ids, boolean queueMode)
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.public Enumeration getQueues()
public Vector getQueueIds(String queue)
public Enumeration getSubs()
public void setQDenyings(Hashtable qDenyings)
public void setSubDenyings(Hashtable subDenyings)
public Vector getSubIds(String sub)
protected int getClassId()
getClassId
in class AbstractJmsMessage
public void writeTo(OutputStream os) throws IOException
writeTo
in interface Streamable
writeTo
in class AbstractJmsRequest
os
- the stream to write the object toIOException
public void readFrom(InputStream is) throws IOException
readFrom
in interface Streamable
readFrom
in class AbstractJmsRequest
is
- the stream to read data from in order to restore the objectIOException
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.