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)
queueMode
- the listener mode.public boolean getQueueMode()
true
for a queue listener.public void setCancelledRequestId(int cancelledRequestId)
cancelledRequestId
- Id of last listener request cancelled by this request.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
- 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.