Modifier and Type | Class and Description |
---|---|
class |
cMsgCallbackAdapter
This class is an adapter which implements the cMsgCallbackInterface.
|
Modifier and Type | Method and Description |
---|---|
cMsgCallbackInterface |
cMsgSubscriptionHandle.getCallback()
Gets the callback object.
|
Modifier and Type | Method and Description |
---|---|
cMsgSubscriptionHandle |
cMsg.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
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 | Method and Description |
---|---|
cMsgSubscriptionHandle |
CA.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Does a CA "monitor on" for this channel.
|
Modifier and Type | Method and Description |
---|---|
int |
cMsgServerClient.serverSendAndGet(cMsgMessage message,
java.lang.String namespace,
cMsgCallbackInterface cb)
The message is sent by a server client to another server as it would be in the
cMsg.send(org.jlab.coda.cMsg.cMsgMessage) method. |
void |
cMsgServerClient.serverSubscribe(java.lang.String subject,
java.lang.String type,
java.lang.String namespace,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method for a server to subscribe to receive messages of a subject
and type from another domain server.
|
void |
cMsgServerClient.serverUnsubscribe(java.lang.String subject,
java.lang.String type,
java.lang.String namespace,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method for a server to unsubscribe a previous subscription to receive messages of a subject and type
from another domain server.
|
cMsgSubscriptionHandle |
cMsg.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
Constructor and Description |
---|
cMsgSendAndGetCallbackThread(cMsgCallbackInterface callback,
java.lang.Object arg)
Constructor used to pass an arbitrary argument to callback method.
|
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 | Method and Description |
---|---|
void |
cMsgServerBridge.sendAndGet(cMsgMessage msg,
java.lang.String namespace,
cMsgCallbackInterface cb)
Method to do a sendAndGet of a message of subject and type to another cMsg server.
|
void |
cMsgServerBridge.subscribeAndGet(java.lang.String subject,
java.lang.String type,
java.lang.String namespace,
cMsgCallbackInterface cb)
Method for a subscribeAndGet (a one-time subscribe) on another cMsg server.
|
void |
cMsgServerBridge.unsubscribeAndGet(java.lang.String subject,
java.lang.String type,
java.lang.String namespace,
cMsgCallbackInterface cb)
Method to remove a previous subscribeAndGet on another cMsg server.
|
Modifier and Type | Field and Description |
---|---|
(package private) cMsgCallbackInterface |
cMsgCallbackThread.callback
Callback to be run.
|
Modifier and Type | Method and Description |
---|---|
cMsgCallbackInterface |
cMsgCallbackThread.getCallback()
Gets the callback object.
|
Modifier and Type | Method and Description |
---|---|
cMsgSubscriptionHandle |
cMsgDomainAdapter.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
cMsgSubscriptionHandle |
cMsgDomainInterface.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
Constructor and Description |
---|
cMsgCallbackThread(cMsgCallbackInterface callback,
java.lang.Object arg,
java.lang.String domain,
java.lang.String subject,
java.lang.String type)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
cMsgSubscriptionHandle |
RunControl.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the rc server.
|
Modifier and Type | Method and Description |
---|---|
cMsgSubscriptionHandle |
RCMulticast.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages from rc clients.
|
Modifier and Type | Method and Description |
---|---|
cMsgSubscriptionHandle |
RCServer.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
This is a method to subscribe to receive messages of a subject and type from the rc client.
|
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 |