public final class ConsumerUnsetListRequest extends AbstractJmsRequest
ConsumerUnsetListRequest
is sent by a
MessageConsumer
which listener is unset.Modifier and Type | Field and Description |
---|---|
private int |
cancelledRequestId
Identifier of the last listener request, cancelled by this
request, queue mode only.
|
private boolean |
queueMode
true if the listener is listening 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 |
---|
ConsumerUnsetListRequest()
Constructs a
ConsumerUnsetListRequest . |
ConsumerUnsetListRequest(boolean queueMode)
Constructs a
ConsumerUnsetListRequest . |
Modifier and Type | Method and Description |
---|---|
int |
getCancelledRequestId()
Returns the identifier of the last listener request, cancelled by this
request, queue mode only.
|
protected int |
getClassId() |
boolean |
getQueueMode()
Returns
true for a queue listener. |
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setCancelledRequestId(int cancelledRequestId)
Sets the identifier of the last listener request, cancelled by this
request, queue mode only.
|
void |
setQueueMode(boolean queueMode)
Sets the listener mode (queue or topic listener).
|
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 boolean queueMode
true
if the listener is listening to a queue.private int cancelledRequestId
public ConsumerUnsetListRequest(boolean queueMode)
ConsumerUnsetListRequest
.queueMode
- true
if the listener is listening to a
queue.public ConsumerUnsetListRequest()
ConsumerUnsetListRequest
.public void setQueueMode(boolean queueMode)
public boolean getQueueMode()
true
for a queue listener.public void setCancelledRequestId(int cancelledRequestId)
public int getCancelledRequestId()
protected int getClassId()
getClassId
in class AbstractJmsMessage
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 © 2019 ScalAgent D.T.. All rights reserved.