public final class SessAckRequest extends AbstractJmsRequest
SessAckRequest
instance is used by a Session
for acknowledging the messages it consumed.Modifier and Type | Field and Description |
---|---|
private Vector<String> |
ids
Vector of message identifiers.
|
private boolean |
queueMode
true if the request is destinated to a queue. |
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 |
---|
SessAckRequest()
Constructs a
SessAckRequest instance. |
SessAckRequest(String targetName,
Vector ids,
boolean queueMode)
Constructs a
SessAckRequest instance. |
Modifier and Type | Method and Description |
---|---|
void |
addId(String id) |
void |
decode(Decoder decoder)
Decodes the content of this object
|
void |
encode(Encoder encoder)
Encodes the content of this object
|
protected int |
getClassId() |
int |
getEncodableClassId()
Returns a unique class identifier.
|
int |
getEncodedSize()
Returns the size of the byte array that results
from the encoding of this object.
|
Vector |
getIds()
Returns the vector of acknowledged messages identifiers.
|
boolean |
getQueueMode()
Returns
true if the request is destinated to a queue. |
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setIds(Vector ids)
Sets the vector of identifiers.
|
void |
setQueueMode(boolean queueMode)
Sets the target destination type.
|
void |
writeTo(OutputStream os)
The object implements the writeTo method to write its contents to
the output stream.
|
getRequestId, getTarget, setRequestId, setTarget, toString, toString
read, readExternal, write, writeExternal
private static final long serialVersionUID
private boolean queueMode
true
if the request is destinated to a queue.public SessAckRequest(String targetName, Vector ids, boolean queueMode)
SessAckRequest
instance.targetName
- Name of the target queue or subscription.ids
- Vector of acknowledged message identifiers.queueMode
- true
if this request is destinated to a
queue.public SessAckRequest()
SessAckRequest
instance.public void setIds(Vector ids)
public void addId(String id)
public Vector getIds()
public void setQueueMode(boolean queueMode)
public boolean getQueueMode()
true
if the request is destinated to a queue.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 getEncodableClassId()
Encodable
getEncodableClassId
in interface Encodable
getEncodableClassId
in class AbstractJmsRequest
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 © 2015 ScalAgent D.T.. All Rights Reserved.