public final class SessDenyRequest extends AbstractJmsRequest
SessDenyRequest
instance is used by a Session
for denying the messages it consumed.Modifier and Type | Field and Description |
---|---|
private boolean |
doNotAck
true if the request must not be acked by the server. |
private Vector |
ids
Vector of message identifiers.
|
private boolean |
queueMode
true if the request is destinated to a queue. |
private boolean |
redelivered
true if the message has already been delivered.
|
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 |
---|
SessDenyRequest()
Public no-arg constructor needed by Externalizable.
|
SessDenyRequest(String targetName,
Vector ids,
boolean queueMode)
Constructs a
SessDenyRequest instance. |
SessDenyRequest(String targetName,
Vector ids,
boolean queueMode,
boolean doNotAck)
Constructs a
SessDenyRequest instance. |
Modifier and Type | Method and Description |
---|---|
void |
addId(String id) |
protected int |
getClassId() |
boolean |
getDoNotAck()
Returns
true if the request must not be acked by the
server. |
Vector |
getIds()
Returns the vector of denyed messages identifiers.
|
boolean |
getQueueMode()
Returns
true if the request is destinated to a queue. |
boolean |
isRedelivered() |
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setDoNotAck(boolean doNotAck)
Sets the server ack policy.
|
void |
setIds(Vector ids)
Sets the vector of identifiers.
|
void |
setQueueMode(boolean queueMode)
Sets the target destination type.
|
void |
setRedelivered(boolean redelivered) |
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 Vector ids
private boolean queueMode
true
if the request is destinated to a queue.private boolean doNotAck
true
if the request must not be acked by the server.private boolean redelivered
public SessDenyRequest(String targetName, Vector ids, boolean queueMode)
SessDenyRequest
instance.targetName
- Name of the target queue or subscription.ids
- Vector of denied message identifiers.queueMode
- true
if this request is destinated to a
queue.public SessDenyRequest(String targetName, Vector ids, boolean queueMode, boolean doNotAck)
SessDenyRequest
instance.targetName
- Name of the target queue or subscription.ids
- Vector of denied message identifiers.queueMode
- true
if this request is destinated to a
queue.doNotAck
- true
if this request must not be acked by
the server.public SessDenyRequest()
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.public void setDoNotAck(boolean doNotAck)
public boolean getDoNotAck()
true
if the request must not be acked by the
server.protected int getClassId()
getClassId
in class AbstractJmsMessage
public boolean isRedelivered()
public void setRedelivered(boolean redelivered)
redelivered
- the redelivered to setpublic 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.