Package | Description |
---|---|
org.jlab.coda.cMsg.cMsgDomain.server | |
org.jlab.coda.cMsg.cMsgDomain.subdomains | |
org.jlab.coda.cMsg.common |
Modifier and Type | Field and Description |
---|---|
(package private) cMsgNotifier |
cMsgServerSendAndGetter.notifier
Wait on this object which tells us when a response message has been sent
to a sendAndGet so we can notify bridges to cancel their sendAndGets.
|
(package private) cMsgNotifier |
cMsgServerSubscribeAndGetter.notifier
Wait on this object which tells us when a matching message has been sent
to a subscribeAndGet so we can notify bridges to cancel their subscriptions
(which are used to implement remote subAndGets).
|
Constructor and Description |
---|
cMsgServerSendAndGetter(cMsgNameServer nameServer,
cMsgNotifier notifier,
java.util.concurrent.ConcurrentHashMap<java.lang.Integer,cMsgServerSendAndGetter> sendAndGetters)
Constructor.
|
cMsgServerSubscribeAndGetter(cMsgNameServer nameServer,
cMsgNotifier notifier,
cMsgCallbackAdapter cb,
java.util.Set<cMsgServerSubscribeInfo> subscriptions,
cMsgServerSubscribeInfo sub)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
int |
cMsg.handleServerSendAndGetRequest(cMsgMessageFull message,
java.lang.String namespace,
cMsgNotifier notifier)
Method to synchronously get a single message from a responder to a
message being sent by the client.
|
void |
cMsg.handleServerSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
cMsgNotifier notifier)
Method for regular client to synchronously get a single message from
the server for a one-time subscription of a subject and type.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<cMsgNotifier> |
cMsgSubscription.getNotifiers()
Gets the set of objects used to notify servers that their subscribeAndGet is complete.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgSubscription.addNotifier(cMsgNotifier notifier)
Add a notifier object to the set of objects used to notify servers that their
subscribeAndGet is complete.
|
void |
cMsgSubscription.removeNotifier(cMsgNotifier notifier)
Remove a notifier object from the set of objects used to notify servers that their
subscribeAndGet is complete.
|