Package | Description |
---|---|
org.jlab.coda.cMsg.apps | |
org.jlab.coda.cMsg.cMsgDomain.server | |
org.jlab.coda.cMsg.test |
Modifier and Type | Class and Description |
---|---|
(package private) static class |
cMsgAlarmServer.cb
Class to implement the callback.
|
(package private) class |
cMsgConsumer.myCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) static class |
cMsgGateway.cb1
Callback for cross-posting.
|
(package private) static class |
cMsgGateway.cb2
Callback for cross-posting.
|
(package private) class |
cMsgGetResponder.myCallback
This class defines our callback object.
|
(package private) static class |
cMsgLogger.cb
Class to implement the callback interface.
|
(package private) class |
cMsgProducer.myCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) static class |
cMsgQueue.getCB
Inner class to implement sendAndGet() callback.
|
(package private) static class |
cMsgQueue.subscribeCB
Inner class to implement subscribe callback.
|
(package private) class |
rcClientKiller.MulticastCallback
Callback for handling RC client trying to connect.
|
Modifier and Type | Class and Description |
---|---|
(package private) static class |
cMsgServerBridge.SendAndGetCallback
This class defines the callback to be run when a sendAndGet response message
arrives from a bridge connection and must be passed on to a client(s).
|
(package private) static class |
cMsgServerBridge.SubscribeCallback
This class defines the callback to be run when a message matching
our subscription arrives from a bridge connection and must be
passed on to a client(s).
|
Modifier and Type | Field and Description |
---|---|
(package private) cMsgCallbackAdapter |
cMsgServerSubscribeAndGetter.cb
Callback for this subscription.
|
Modifier and Type | Field and Description |
---|---|
(package private) java.util.HashMap<java.lang.Integer,cMsgCallbackAdapter> |
cMsgServerSubscribeInfo.subAndGetters
This map contains all regular clients (servers do not call
subscribeAndGet but use subscribe to implement it) who have
called
cMsg.subscribeAndGet(java.lang.String, java.lang.String, int)
with this exact subject, type, and namespace. |
Modifier and Type | Method and Description |
---|---|
static cMsgCallbackAdapter |
cMsgServerBridge.getSendAndGetCallback(int id,
int sysMsgId)
Get a callback for a sendAndGet call.
|
static cMsgCallbackAdapter |
cMsgServerBridge.getSubAndGetCallback()
This method returns a reference to the one callback needed for
subscribes and subAndGets to propogate messages back to
original client.
|
Modifier and Type | Method and Description |
---|---|
java.util.HashMap<java.lang.Integer,cMsgCallbackAdapter> |
cMsgServerSubscribeInfo.getSubAndGetters()
Gets the HashMap containing the subscribeAndGet id generated by the originating client
as the key (receiverSubscribeId which identifies the particular subscribeAndGet call
in question), and the value which is the callback object of that subscribeAndGet.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgServerSubscribeInfo.addSubAndGetter(int id,
cMsgCallbackAdapter cb)
Adds an entry to a hashmap with the subscribeAndGet id as the key and the callback object
as the value.
|
Constructor and Description |
---|
cMsgServerSubscribeAndGetter(cMsgNameServer nameServer,
cMsgNotifier notifier,
cMsgCallbackAdapter cb,
java.util.Set<cMsgServerSubscribeInfo> subscriptions,
cMsgServerSubscribeInfo sub)
Constructor.
|
cMsgServerSubscribeInfo(java.lang.String subject,
java.lang.String type,
java.lang.String namespace,
cMsgClientInfo info,
int id,
cMsgCallbackAdapter cb)
Constructor used by cMsgDomainServer object basically for storage of subject, type,
namespace and callbacks for subAndGets.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
cMsgTest.myCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) class |
cMsgTestPayload.myCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) class |
cMsgTestRcClient.myCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) class |
cMsgTestRcClient.sAndGCallback
This class defines our callback object.
|
(package private) class |
cMsgTestRcServer.MulticastCallback |
(package private) class |
cMsgTestRcServer.rcCallback |
(package private) class |
DoubleTest.DoubleReceivingCallback
This class defines the callback to be run when a double arrives.
|
(package private) class |
DoubleTest.DoubleSendingCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) class |
DoubleTestReceiver.DoubleReceivingCallback
This class defines the callback to be run when a double arrives.
|
(package private) class |
DoubleTestSender.DoubleSendingCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) class |
RCClientReconnect.myCallback
This class defines the callback to be run when a message matching
our subscription arrives.
|
(package private) class |
RCMulticastServer.MulticastCallback |
(package private) class |
RCMulticastServer.rcCallback |
(package private) class |
RCMulticastServer.starCallback |
(package private) class |
UnsubTest.ReceivingCallback
This class defines the callback to be run - sleeps for 1 sec.
|
(package private) class |
VardanClient.receivingCb |
(package private) class |
VardanClient.startCb |
(package private) class |
VardanServer.adminCb |
(package private) class |
VardanServer.sendingCb |