public final class CommitRequest extends AbstractJmsRequest
Modifier and Type | Field and Description |
---|---|
private Vector |
ackRequests
List of SessAckRequest
|
private boolean |
asyncSend
Indicates whether the produced messages
are asynchronously send or not
(without or with an acknowledgement).
|
private Vector |
producerMessages
List of ProducerMessages
|
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 |
---|
CommitRequest() |
Modifier and Type | Method and Description |
---|---|
void |
addAckRequest(SessAckRequest sar) |
void |
addProducerMessages(ProducerMessages pm) |
Enumeration |
getAckRequests() |
boolean |
getAsyncSend() |
protected int |
getClassId() |
Enumeration |
getProducerMessages() |
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setAsyncSend(boolean b) |
void |
toString(StringBuffer strbuf) |
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
read, readExternal, write, writeExternal
private static final long serialVersionUID
private Vector producerMessages
private Vector ackRequests
private boolean asyncSend
protected int getClassId()
getClassId
in class AbstractJmsMessage
public void addProducerMessages(ProducerMessages pm)
public void addAckRequest(SessAckRequest sar)
public Enumeration getProducerMessages()
public Enumeration getAckRequests()
public void setAsyncSend(boolean b)
public final boolean getAsyncSend()
public void toString(StringBuffer strbuf)
toString
in class AbstractJmsRequest
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 © 2018 ScalAgent D.T.. All Rights Reserved.