hidden abstract class %BigData.Messaging extends %RegisteredObject
This class provides an abstract messaging API, internal to the sharding framework, that permits alternate underlying mechanisms to be substituted (e.g. TCP/IP devices or ECP/semaphores). In all methods, "client" and "server" may both be instances of shard server. In the descriptions, "client" and "server" refer to the role they are playing in the current messaging dialogue. Server side method to read a message from client.
Array of messaging devices subscripted by shard indexproperty msg as %String;
The most recently received message from the client (set by srvrecv()).property msgCode as %String;
The message code from the most recently received message from the client.property shards [ MultiDimensional ];
Array of shard addresses corresponding to devsproperty ssio ;
The server's I/O device
Close the specified devicemethod clirecv(dev) as %String
Client side method to read a reply from the server.method clisend(dev, msg, qryId)
Client side method to send a message to server.method reconnect(pMsgConnection) as %Status
Reconnect, after a dropped connectionmethod srvackclose()
Server acknowledge client's close requestmethod srvclose()
Close the server's devicemethod srvrecv() as %Library.Status
Server side method to receive a reply from a client. Sets msg to contain the message received (minus the message code), and msgCode to contain its message code.method srvsend(reply)
Server side method to send a reply to a client.