Modifier and Type | Method and Description |
---|---|
cMsgMessage |
cMsgMessage.copy()
Creates a complete copy of this message.
|
cMsgMessage |
cMsgPayloadItem.getMessage()
Gets the payload item as a cMsgMessage object.
|
cMsgMessage[] |
cMsgPayloadItem.getMessageArray()
Gets the payload item as an array of cMsgMessage objects.
|
cMsgMessage |
cMsg.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the domain the user is connected to.
|
cMsgMessage |
cMsgMessage.nullResponse()
Creates a proper response message to this message which was sent by a client calling
sendAndGet.
|
cMsgMessage |
cMsgMessage.response()
Creates a proper response message to this message which was sent by a client calling
sendAndGet.
|
cMsgMessage |
cMsg.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsg.send(cMsgMessage) method. |
cMsgMessage |
cMsg.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgCallbackAdapter.callback(cMsgMessage msg,
java.lang.Object userObject)
Callback method definition.
|
void |
cMsgCallbackInterface.callback(cMsgMessage msg,
java.lang.Object userObject)
Callback method definition.
|
static void |
cMsgMessage.copy(cMsgMessage src,
cMsgMessage dst)
This method turns the destination message into a complete copy of the source message.
|
void |
cMsgMessage.copyPayload(cMsgMessage msg)
Copy only the payload of the given message, overwriting
the existing payload.
|
void |
cMsgMessage.makeNullResponse(cMsgMessage msg)
Converts existing message to null response of supplied message.
|
void |
cMsgMessage.makeResponse(cMsgMessage msg)
Converts existing message to response of supplied message.
|
void |
cMsg.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
cMsgMessage |
cMsg.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsg.send(cMsgMessage) method. |
int |
cMsg.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the domain that got it.
|
Constructor and Description |
---|
cMsgMessage(cMsgMessage msg)
The constructor which copies a given message.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage msg)
Construct a payload item from a cMsgMessage object.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage[] msgs)
Construct a payload item from an array of cMsgMessage objects.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage[] msgs,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of cMsgMessage objects.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage msg,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a cMsgMessage object.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgConsumer.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject)
Callback method definition.
|
void |
cMsgProducer.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgAlarmServer.cb.callback(cMsgMessage msg,
java.lang.Object userObject)
Called when message arrives, logs to screen, file, and/or database.
|
void |
cMsgGetResponder.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
rcClientKiller.MulticastCallback.callback(cMsgMessage msg,
java.lang.Object userObject)
This callback is called when a client is trying to connect to
this multicast server.
|
void |
cMsgGateway.cb1.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgGateway.cb2.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgQueue.subscribeCB.callback(cMsgMessage m,
java.lang.Object userObject)
Queues message to file or database.
|
void |
cMsgQueue.getCB.callback(cMsgMessage m,
java.lang.Object userObject)
Retrieves oldest entry in file or database queue and returns as getResponse.
|
void |
cMsgLogger.cb.callback(cMsgMessage msg,
java.lang.Object userObject)
Called when message arrives, logs to screen, file, and/or database.
|
static void |
cMsgAlarmServer.logToDatabase(cMsgMessage msg) |
Modifier and Type | Method and Description |
---|---|
cMsgMessage |
CA.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
Get the channel's value and place it in the return message's text field.
|
Modifier and Type | Method and Description |
---|---|
void |
CA.send(cMsgMessage msg)
Set double value of channel from message's text field.
|
Modifier and Type | Method and Description |
---|---|
cMsgMessage |
cMsg.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the cMsg domain the user is connected to.
|
cMsgMessage |
cMsg.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
cMsgMessage |
cMsg.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsg.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
cMsgMessage |
cMsg.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
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. |
int |
cMsg.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the subdomain handler that got it.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgServerBridge.SubscribeCallback.callback(cMsgMessage msg,
java.lang.Object userObject)
Callback which passes on a message to other clients.
|
void |
cMsgServerBridge.SendAndGetCallback.callback(cMsgMessage msg,
java.lang.Object userObject)
Callback which passes on a message to local clients.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgMessageDeliverer.deliverMessage(cMsgMessage msg,
int msgType)
Method to deliver a message from a domain server's subdomain handler to a client.
|
void |
cMsg.localSend(cMsgMessage message,
java.lang.String namespace)
This method handles a message sent by a local bridge object's callback.
|
Modifier and Type | Class and Description |
---|---|
class |
cMsgMessageFull
This class contains the full functionality of a message.
|
Modifier and Type | Method and Description |
---|---|
cMsgMessage[] |
cMsgServerFinder.getCmsgServers()
Return an array of cMsg messages contains payload items of the cmsg name servers
information found in the last search.
|
cMsgMessage[] |
cMsgServerFinder.getRcServers()
Return an array of cMsg messages contains payload items of the rc multicast servers
information found in the last search.
|
cMsgMessage |
cMsgDomainAdapter.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the cMsg domain the user is connected to.
|
cMsgMessage |
cMsgDomainInterface.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the cMsg domain the user is connected to.
|
static cMsgMessage |
cMsgMessageFull.parseXml(java.lang.String XML)
This method parses an XML string representing a cMsg message
(using a DOM parser) and turns it into a cMsg message.
|
cMsgMessage |
cMsgDomainAdapter.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
cMsgMessage |
cMsgDomainInterface.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
cMsgMessage |
cMsgDomainAdapter.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
cMsgMessage |
cMsgDomainInterface.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
Modifier and Type | Method and Description |
---|---|
void |
cMsgDeliverMessageInterface.deliverMessage(cMsgMessage msg,
int msgType)
Method to deliver a message from a domain server's subdomain handler to a client.
|
void |
cMsgDomainAdapter.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
void |
cMsgDomainInterface.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
cMsgMessage |
cMsgDomainAdapter.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
cMsgMessage |
cMsgDomainInterface.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
int |
cMsgDomainAdapter.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the subdomain handler that got it.
|
int |
cMsgDomainInterface.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the subdomain handler that got it.
|
Constructor and Description |
---|
cMsgMessageFull(cMsgMessage m)
Constructor using existing cMsgMessage type of message.
|
Modifier and Type | Method and Description |
---|---|
void |
EmuClient.send(cMsgMessage message)
Method to send a message to the Emu domain server.
|
Modifier and Type | Method and Description |
---|---|
void |
File.send(cMsgMessage msg)
Writes to file.
|
int |
File.syncSend(cMsgMessage message,
int timeout)
Calls send to write to file.
|
Modifier and Type | Method and Description |
---|---|
cMsgMessage |
RunControl.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
from the rc multicast server specified in the UDL.
|
Modifier and Type | Method and Description |
---|---|
void |
RunControl.send(cMsgMessage message)
Method to send a message to the domain server for further distribution.
|
Modifier and Type | Method and Description |
---|---|
void |
RCMulticast.send(cMsgMessage message)
Method to send an abort command to the rc client.
|
Modifier and Type | Method and Description |
---|---|
cMsgMessage |
RCServer.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
RCServer.send(org.jlab.coda.cMsg.cMsgMessage) method except that the
senderToken and creator are set. |
cMsgMessage |
RCServer.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
Modifier and Type | Method and Description |
---|---|
void |
RCServer.send(cMsgMessage message)
Method to send a message/command to the rc client.
|
cMsgMessage |
RCServer.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
RCServer.send(org.jlab.coda.cMsg.cMsgMessage) method except that the
senderToken and creator are set. |
int |
RCServer.syncSend(cMsgMessage message,
int timeout)
Method to send a "ping" command to the rc client.
|
Modifier and Type | Method and Description |
---|---|
cMsgMessage |
ConstructorInfo.createMessageFromArgs()
Take argument specification data and store it in a cMsg message.
|
Modifier and Type | Method and Description |
---|---|
void |
TCPS.send(cMsgMessage message)
Method to send a message/command to the TCPServer.
|
Modifier and Type | Method and Description |
---|---|
void |
RCMulticastServer.MulticastCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
RCMulticastServer.rcCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
RCMulticastServer.starCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
VardanServer.adminCb.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
VardanServer.sendingCb.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
RCClientReconnect.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
UnsubTest.ReceivingCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgTestRcServer.MulticastCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgTestRcServer.rcCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
DoubleTestReceiver.DoubleReceivingCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
DoubleTestSender.DoubleSendingCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgTest.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
VardanClient.startCb.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
VardanClient.receivingCb.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgTestRcClient.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgTestRcClient.sAndGCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
cMsgTestPayload.myCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
DoubleTest.DoubleSendingCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |
void |
DoubleTest.DoubleReceivingCallback.callback(cMsgMessage msg,
java.lang.Object userObject) |