public final class ConsumerDenyRequest extends AbstractJmsRequest
ConsumerDenyRequest
instance is used by a
MessageConsumer
for denying a received message.Modifier and Type | Field and Description |
---|---|
private boolean |
doNotAck
true if the request must not be acked by the server. |
private String |
id
Message identifier.
|
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 |
---|
ConsumerDenyRequest()
Constructs a
ConsumerDenyRequest instance. |
ConsumerDenyRequest(String targetName,
String id,
boolean queueMode)
Constructs a
ConsumerDenyRequest instance. |
ConsumerDenyRequest(String targetName,
String id,
boolean queueMode,
boolean doNotAck)
Constructs a
ConsumerDenyRequest instance. |
Modifier and Type | Method and Description |
---|---|
protected int |
getClassId() |
boolean |
getDoNotAck()
Returns
true if the request must not be acked by the
server. |
String |
getId()
Returns the denied message identifier.
|
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 |
setId(String id)
Sets the denied message identifier.
|
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 String id
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 ConsumerDenyRequest(String targetName, String id, boolean queueMode)
ConsumerDenyRequest
instance.targetName
- Name of the target queue or subscription.id
- The message identifier.queueMode
- true
if this request is destinated to
a queue.public ConsumerDenyRequest(String targetName, String id, boolean queueMode, boolean doNotAck)
ConsumerDenyRequest
instance.targetName
- Name of the target queue or subscription.id
- The message identifier.queueMode
- true
if this request is destinated to
a queue.doNotAck
- true
if this request must not be acked by
the server.public ConsumerDenyRequest()
ConsumerDenyRequest
instance.public void setId(String id)
public String getId()
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.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
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 © 2019 ScalAgent D.T.. All rights reserved.