public final class ConsumerSetListRequest extends AbstractJmsRequest
ConsumerSetListRequest
is sent by a
MessageConsumer
on which a message listener is set.Modifier and Type | Field and Description |
---|---|
private int |
msgCount |
private String[] |
msgIdsToAck |
private boolean |
queueMode
true if the request is destinated to a queue. |
private String |
selector
Selector for filtering messages on 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 |
---|
ConsumerSetListRequest()
Constructs a
ConsumerSetListRequest . |
ConsumerSetListRequest(String targetName,
String selector,
boolean queueMode,
String[] msgIdsToAck,
int msgCount)
Constructs a
ConsumerSetListRequest . |
Modifier and Type | Method and Description |
---|---|
protected int |
getClassId() |
int |
getMessageCount() |
String[] |
getMessageIdsToAck() |
boolean |
getQueueMode()
Returns
true if the request is destinated to a queue. |
String |
getSelector()
Returns the selector for filtering messages.
|
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setQueueMode(boolean queueMode)
Sets the target destination type.
|
void |
setSelector(String selector)
Sets the selector.
|
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 String selector
private boolean queueMode
true
if the request is destinated to a queue.private String[] msgIdsToAck
private int msgCount
public ConsumerSetListRequest(String targetName, String selector, boolean queueMode, String[] msgIdsToAck, int msgCount)
ConsumerSetListRequest
.targetName
- Name of the target queue or subscription.selector
- Selector for filtering messages.queueMode
- true
if this request is destinated to a
queue.public ConsumerSetListRequest()
ConsumerSetListRequest
.public void setSelector(String selector)
public String getSelector()
public void setQueueMode(boolean queueMode)
public boolean getQueueMode()
true
if the request is destinated to a queue.public final String[] getMessageIdsToAck()
public final int getMessageCount()
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 © 2013 ScalAgent D.T.. All Rights Reserved.