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 destination is 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 denied messages identifiers.
|
boolean |
getQueueMode()
Returns
true if the request destination is 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 destination is 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)
ids
- The identifiers of denied messages.public void addId(String id)
public Vector getIds()
public void setQueueMode(boolean queueMode)
queueMode
- The destination type.public boolean getQueueMode()
true
if the request destination is a queue.public void setDoNotAck(boolean doNotAck)
doNotAck
- True if the request doesn't need ack.public boolean getDoNotAck()
true
if the request must not be acked by the server.public boolean isRedelivered()
public void setRedelivered(boolean redelivered)
redelivered
- the redelivered to setprotected 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.Copyright © 2021 ScalAgent D.T.. All rights reserved.