public class SubscribeRequest extends AbstractRequestNot
SubscribeRequest
instance is used by a client agent
for subscribing to a topic.Modifier and Type | Field and Description |
---|---|
private boolean |
asyncSub
asynchronous subscription request.
|
private String |
selector
Selector for filtering messages, null or empty string for no selection.
|
private static long |
serialVersionUID |
detachable, detached, persistent
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
SubscribeRequest(int clientContext,
int requestId,
String selector,
boolean asyncSub)
Constructs a
SubscribeRequest instance. |
Modifier and Type | Method and Description |
---|---|
String |
getSelector()
Returns the selector.
|
boolean |
isAsyncSub() |
decode, encode, getEncodedSize, getRequestId, toString
getClientContext, setPersistent
done, failed, hasCallback, passCallback, setCountDownCallback
clone, getContext, getDeadNotificationAgentId, getEncodableClassId, getExpiration, getMessageId, getPriority, isPersistent, setContext, setDeadNotificationAgentId, setExpiration, setPriority, toString
private static final long serialVersionUID
private String selector
private boolean asyncSub
public SubscribeRequest(int clientContext, int requestId, String selector, boolean asyncSub)
SubscribeRequest
instance.clientContext
- Identifies a client context.requestId
- Request identifier.selector
- Selector expression for filtering messages, null or
empty string for no selection.asyncSub
- true if asynchronous subscription.public boolean isAsyncSub()
public String getSelector()
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.