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
define serialVersionUID for interoperability
|
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<ProducerMessages> sendings,
Vector<SessAckRequest> 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<SessAckRequest> |
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<ProducerMessages> |
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<ProducerMessages> sendings, Vector<SessAckRequest> 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<ProducerMessages> getSendings()
ProducerMessages
instances.public void addProducerMessages(ProducerMessages pm)
public Vector<SessAckRequest> 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
- an error occurs during IO operation.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
- an error occurs during IO operation.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 © 2023 ScalAgent D.T.. All rights reserved.