public final class ConsumerSubRequest extends AbstractJmsRequest
ConsumerSubRequest
is sent by a constructing
MessageConsumer
destinated to consume messages on a topic.Modifier and Type | Field and Description |
---|---|
private boolean |
asyncSub
asynchronous subscription.
|
private String |
clientID |
private boolean |
durable
true if the subscription is durable. |
private boolean |
noLocal
true if the subscriber does not wish to consume messages
produced by its connection. |
private String |
selector
The selector for filtering messages.
|
private static long |
serialVersionUID |
private boolean |
shared |
private String |
subName
The subscription's name.
|
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 |
---|
ConsumerSubRequest()
Constructs a
ConsumerSubRequest . |
ConsumerSubRequest(String topic,
String subName,
String selector,
boolean noLocal,
boolean durable,
boolean asyncSub,
String clientID,
boolean shared)
Constructs a
ConsumerSubRequest . |
Modifier and Type | Method and Description |
---|---|
protected int |
getClassId() |
String |
getClientID() |
boolean |
getDurable()
Returns
true for a durable subscription. |
boolean |
getNoLocal()
Returns
true for not consuming the local messages. |
String |
getSelector()
Returns the selector for filtering the messages.
|
String |
getSubName()
Returns the name of the subscription.
|
boolean |
isAsyncSubscription()
Returns
true for asynchronous subscription. |
boolean |
isShared() |
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setDurable(boolean durable)
Sets the durable attribute.
|
void |
setNoLocal(boolean noLocal)
Sets the noLocal attribute.
|
void |
setSelector(String selector)
Sets the selector.
|
void |
setSubName(String subName)
Sets the subscription name.
|
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 subName
private boolean asyncSub
private String selector
private boolean noLocal
true
if the subscriber does not wish to consume messages
produced by its connection.private boolean durable
true
if the subscription is durable.private String clientID
private boolean shared
public ConsumerSubRequest(String topic, String subName, String selector, boolean noLocal, boolean durable, boolean asyncSub, String clientID, boolean shared)
ConsumerSubRequest
.topic
- The topic identifier the client wishes to subscribe to.subName
- The subscription's name.selector
- The selector for filtering messages, if any.noLocal
- true
for not consuming the local messages.durable
- true
for a durable subscription.asyncSub
- true
for a asynchronous subscription request.clientID
- The clientIDshared
- true if the consumer is sharedpublic ConsumerSubRequest()
ConsumerSubRequest
.public void setSubName(String subName)
public String getSubName()
public void setSelector(String selector)
public String getSelector()
public void setNoLocal(boolean noLocal)
public boolean getNoLocal()
true
for not consuming the local messages.public void setDurable(boolean durable)
public boolean getDurable()
true
for a durable subscription.public String getClientID()
public boolean isShared()
public boolean isAsyncSubscription()
true
for asynchronous subscription.protected 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.