Class SubscribeRequest
- java.lang.Object
-
- fr.dyade.aaa.agent.Notification
-
- fr.dyade.aaa.agent.CallbackNotification
-
- org.objectweb.joram.mom.notifications.AbstractNotification
-
- org.objectweb.joram.mom.notifications.AbstractRequestNot
-
- org.objectweb.joram.mom.notifications.SubscribeRequest
-
- All Implemented Interfaces:
Encodable,Serializable,Cloneable
public class SubscribeRequest extends AbstractRequestNot
ASubscribeRequestinstance is used by a client agent for subscribing to a topic.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description private booleanasyncSubasynchronous subscription request.private StringselectorSelector for filtering messages, null or empty string for no selection.private static longserialVersionUID-
Fields inherited from class fr.dyade.aaa.agent.Notification
detachable, detached, persistent
-
Fields inherited from interface fr.dyade.aaa.common.encoding.Encodable
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
-
-
Constructor Summary
Constructors Constructor Description SubscribeRequest(int clientContext, int requestId, String selector, boolean asyncSub)Constructs aSubscribeRequestinstance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetSelector()Returns the selector.booleanisAsyncSub()-
Methods inherited from class org.objectweb.joram.mom.notifications.AbstractRequestNot
decode, encode, getEncodedSize, getRequestId, toString
-
Methods inherited from class org.objectweb.joram.mom.notifications.AbstractNotification
getClientContext, setPersistent
-
Methods inherited from class fr.dyade.aaa.agent.CallbackNotification
done, failed, hasCallback, passCallback, setCountDownCallback
-
Methods inherited from class fr.dyade.aaa.agent.Notification
clone, getContext, getDeadNotificationAgentId, getEncodableClassId, getExpiration, getMessageId, getPriority, isPersistent, setContext, setDeadNotificationAgentId, setExpiration, setPriority, toString
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
selector
private String selector
Selector for filtering messages, null or empty string for no selection.
-
asyncSub
private boolean asyncSub
asynchronous subscription request.
-
-
Constructor Detail
-
SubscribeRequest
public SubscribeRequest(int clientContext, int requestId, String selector, boolean asyncSub)Constructs aSubscribeRequestinstance.- Parameters:
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.
-
-
Method Detail
-
isAsyncSub
public boolean isAsyncSub()
- Returns:
- true for asynchronous subscription request.
-
getSelector
public String getSelector()
Returns the selector.
-
-