public final class ConsumerReceiveRequest extends AbstractJmsRequest
ConsumerReceiveRequest
is sent by a
MessageConsumer
when requesting a message.Modifier and Type | Field and Description |
---|---|
private boolean |
queueMode
true if the request is destinated to a queue. |
private boolean |
receiveAck |
private String |
selector
The selector for filtering messages on a queue.
|
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
private long |
timeToLive
The time to live value of the request (negative for infinite).
|
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 |
---|
ConsumerReceiveRequest()
Constructs a
ConsumerReceiveRequest . |
ConsumerReceiveRequest(String targetName,
String selector,
long timeToLive,
boolean queueMode)
Constructs a
ConsumerReceiveRequest . |
Modifier and Type | Method and Description |
---|---|
protected int |
getClassId() |
boolean |
getQueueMode()
Returns
true if the request is destinated to a queue. |
boolean |
getReceiveAck() |
String |
getSelector()
Returns the selector for filtering the messages.
|
long |
getTimeToLive()
Returns the time to live value in milliseconds.
|
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 |
setReceiveAck(boolean receiveAck) |
void |
setSelector(String selector)
Sets the selector.
|
void |
setTimeToLive(long timeToLive)
Sets the time to live value.
|
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 selector
private long timeToLive
private boolean queueMode
true
if the request is destinated to a queue.private boolean receiveAck
public ConsumerReceiveRequest(String targetName, String selector, long timeToLive, boolean queueMode)
ConsumerReceiveRequest
.targetName
- Name of the target queue or subscription.selector
- The selector for filtering messages, if any.timeToLive
- Time to live value in milliseconds, negative for
infinite.queueMode
- true
if this request is destinated to a
queue.public ConsumerReceiveRequest()
ConsumerReceiveRequest
.public void setSelector(String selector)
public String getSelector()
public void setTimeToLive(long timeToLive)
public long getTimeToLive()
public void setQueueMode(boolean queueMode)
public boolean getQueueMode()
true
if the request is destinated to a queue.public void setReceiveAck(boolean receiveAck)
public final boolean getReceiveAck()
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 © 2018 ScalAgent D.T.. All Rights Reserved.