public final class XACnxPrepare extends AbstractJmsRequest
XACnxPrepare
instance is used by an
XAConnection
for sending messages and acknowledgements to
the proxy.Modifier and Type | Field and Description |
---|---|
private Vector<SessAckRequest> |
acks
Vector of
SessAckRequest instances. |
private byte[] |
bq
Transaction branch qualifier.
|
private int |
fi
Transaction identifier format.
|
private byte[] |
gti
Global transaction identifier.
|
private Vector<ProducerMessages> |
sendings
Vector of
ProducerMessages instances. |
private static long |
serialVersionUID |
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 |
---|
XACnxPrepare() |
XACnxPrepare(byte[] bq,
int fi,
byte[] gti,
Vector sendings,
Vector acks)
Constructs an
XACnxPrepare instance. |
Modifier and Type | Method and Description |
---|---|
void |
addProducerMessages(ProducerMessages pm) |
void |
addSessAckRequest(SessAckRequest sar) |
void |
decode(Decoder decoder)
Decodes the content of this object
|
void |
encode(Encoder encoder)
Encodes the content of this object
|
Vector |
getAcks()
Returns the vector of
SessAckRequest instances. |
byte[] |
getBQ()
Returns the transaction branch qualifier.
|
protected int |
getClassId() |
int |
getEncodedSize()
Returns the size of the byte array that results
from the encoding of this object.
|
int |
getFI()
Returns the transaction identifier format.
|
byte[] |
getGTI()
Returns the global transaction identifier.
|
Vector |
getSendings()
Returns the vector of
ProducerMessages instances. |
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 |
writeTo(OutputStream os)
The object implements the writeTo method to write its contents to
the output stream.
|
getEncodableClassId, 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 Vector<ProducerMessages> sendings
ProducerMessages
instances.private Vector<SessAckRequest> acks
SessAckRequest
instances.public XACnxPrepare(byte[] bq, int fi, byte[] gti, Vector sendings, Vector acks)
XACnxPrepare
instance.bq
- Transaction branch qualifier.fi
- Transaction identifier format.gti
- Global transaction identifier.sendings
- Vector of ProducerMessages
instances.acks
- Vector of SessAckRequest
instances.public XACnxPrepare()
public byte[] getBQ()
public void setBQ(byte[] bq)
public int getFI()
public void setFI(int fi)
public byte[] getGTI()
public void setGTI(byte[] gti)
public Vector getSendings()
ProducerMessages
instances.public void addProducerMessages(ProducerMessages pm)
public Vector getAcks()
SessAckRequest
instances.public void addSessAckRequest(SessAckRequest sar)
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
public int getEncodedSize() throws Exception
Encodable
getEncodedSize
in interface Encodable
getEncodedSize
in class AbstractJmsRequest
Exception
- if an error occurspublic void encode(Encoder encoder) throws Exception
Encodable
encode
in interface Encodable
encode
in class AbstractJmsRequest
encoder
- the encoder to be used for the encodingException
- if an error occurspublic void decode(Decoder decoder) throws Exception
Encodable
decode
in interface Encodable
decode
in class AbstractJmsRequest
decoder
- the decoder to be used for the decodingException
- if an error occursCopyright © 2020 ScalAgent D.T.. All rights reserved.