#include <cMsg.hxx>
Definition at line 363 of file cMsg.hxx.
Public Member Functions | |
cMsg (const string &UDL, const string &name, const string &descr) | |
Constructor for cMsg system object. | |
virtual | ~cMsg (void) |
Destructor disconects from cMsg system. | |
virtual void | connect () throw (cMsgException) |
Connects to cMsg system. | |
virtual void | disconnect (void) throw (cMsgException) |
Disconnects from cMsg system. | |
virtual void | send (cMsgMessage &msg) throw (cMsgException) |
Sends message. | |
virtual void | send (cMsgMessage *msg) throw (cMsgException) |
Sends message. | |
virtual int | syncSend (cMsgMessage &msg, const struct timespec *timeout=NULL) throw (cMsgException) |
Synchronously sends message. | |
virtual int | syncSend (cMsgMessage *msg, const struct timespec *timeout=NULL) throw (cMsgException) |
Synchronously sends message. | |
virtual void * | subscribe (const string &subject, const string &type, cMsgCallback *cb, void *userArg, const cMsgSubscriptionConfig *cfg=NULL) throw (cMsgException) |
Subscribes to subject,type and specifies callback, userArg. | |
virtual void * | subscribe (const string &subject, const string &type, cMsgCallback &cb, void *userArg, const cMsgSubscriptionConfig *cfg=NULL) throw (cMsgException) |
Subscribes to subject,type and specifies callback,userArg. | |
virtual void | unsubscribe (void *handle) throw (cMsgException) |
Unsubscribes. | |
virtual void | subscriptionPause (void *handle) throw (cMsgException) |
Pause delivery of messages to the given subscription's callback. | |
virtual void | subscriptionResume (void *handle) throw (cMsgException) |
Resume delivery of messages to the given subscription's callback if paused. | |
virtual void | subscriptionQueueClear (void *handle) throw (cMsgException) |
Clear all messages from the given subscription callback's queue. | |
virtual int | subscriptionQueueCount (void *handle) throw (cMsgException) |
Return the number of messages currently in the given subscription callback's queue. | |
virtual bool | subscriptionQueueIsFull (void *handle) throw (cMsgException) |
Returns whether the given subscription callback's queue is full (true) or not. | |
virtual int | subscriptionMessagesTotal (void *handle) throw (cMsgException) |
Return the total number of messages passed to the given subscription's callback. | |
virtual cMsgMessage * | sendAndGet (cMsgMessage &sendMsg, const struct timespec *timeout=NULL) throw (cMsgException) |
Sends message and gets reply. | |
virtual cMsgMessage * | sendAndGet (cMsgMessage *sendMsg, const struct timespec *timeout=NULL) throw (cMsgException) |
Sends message and gets reply. | |
virtual cMsgMessage * | subscribeAndGet (const string &subject, const string &type, const struct timespec *timeout=NULL) throw (cMsgException) |
Subscribes to subject/type, returns one matching message, then unsubscribes. | |
virtual void | flush (const struct timespec *timeout=NULL) throw (cMsgException) |
Flushes outgoing message queues. | |
virtual void | start (void) throw (cMsgException) |
Enables delivery of messages to callbacks. | |
virtual void | stop (void) throw (cMsgException) |
Disables delivery of messages to callbacks. | |
virtual void | setUDL (const string &udl) throw (cMsgException) |
Sets the connection UDL. | |
virtual string | getUDL (void) const |
Gets connection UDL. | |
virtual string | getCurrentUDL (void) const throw (cMsgException) |
Gets UDL of the current connection, "null" if no connection. | |
virtual string | getName (void) const |
Gets connection name. | |
virtual string | getDescription (void) const |
Gets connection description. | |
virtual bool | isConnected (void) const throw (cMsgException) |
True if connected. | |
virtual bool | isReceiving (void) const throw (cMsgException) |
True if receiving messages. | |
virtual void | setShutdownHandler (cMsgShutdownHandler *handler, void *userArg) throw (cMsgException) |
Sets shutdown handler. | |
virtual void | shutdownClients (const string &client, int flag) throw (cMsgException) |
Shuts down a client. | |
virtual void | shutdownServers (const string &server, int flag) throw (cMsgException) |
Shuts down a server. | |
virtual cMsgMessage * | monitor (const string &monString) throw (cMsgException) |
Returns domain-dependent monitoring information. |
|
Constructor for cMsg system object.
Definition at line 1642 of file cMsgWrapper.cc. |
|
Destructor disconects from cMsg system.
Definition at line 1654 of file cMsgWrapper.cc. |
|
Connects to cMsg system. If a connection has already been made, a reconnection will be attempted. In a reconnection, if there is no current connection one will be made. If there is a current, healthy connection and if the UDL to which a connection attempt will be made is identical to the currentUDL, nothing is done. If there is a current, healthy connection, and if the UDL to which a connection attempt will be made is different from the current UDL, the current connection will be disconnected and a new connection attempted with the new UDL.
Definition at line 1673 of file cMsgWrapper.cc. |
|
Disconnects from cMsg system.
Definition at line 1699 of file cMsgWrapper.cc. |
|
Flushes outgoing message queues.
Definition at line 2131 of file cMsgWrapper.cc. |
|
Gets UDL of the current connection, "null" if no connection.
Definition at line 2248 of file cMsgWrapper.cc. |
|
Gets connection description.
Definition at line 2189 of file cMsgWrapper.cc. |
|
Gets connection name.
Definition at line 2202 of file cMsgWrapper.cc. |
|
Gets connection UDL.
Definition at line 2215 of file cMsgWrapper.cc. |
|
True if connected.
Definition at line 2273 of file cMsgWrapper.cc. |
|
True if receiving messages.
Definition at line 2295 of file cMsgWrapper.cc. |
|
Returns domain-dependent monitoring information.
Definition at line 2384 of file cMsgWrapper.cc. |
|
Sends message.
Definition at line 1739 of file cMsgWrapper.cc. |
|
Sends message.
Definition at line 1718 of file cMsgWrapper.cc. |
|
Sends message and gets reply.
Definition at line 2078 of file cMsgWrapper.cc. |
|
Sends message and gets reply.
Definition at line 2050 of file cMsgWrapper.cc. |
|
Sets shutdown handler.
Definition at line 2318 of file cMsgWrapper.cc. |
|
Sets the connection UDL. Any subsequent failovers or reconnects will use the new UDL.
Definition at line 2230 of file cMsgWrapper.cc. |
|
Shuts down a client.
Definition at line 2340 of file cMsgWrapper.cc. |
|
Shuts down a server.
Definition at line 2362 of file cMsgWrapper.cc. |
|
Enables delivery of messages to callbacks.
Definition at line 2150 of file cMsgWrapper.cc. |
|
Disables delivery of messages to callbacks.
Definition at line 2169 of file cMsgWrapper.cc. |
|
Subscribes to subject,type and specifies callback,userArg.
Definition at line 1857 of file cMsgWrapper.cc. |
|
Subscribes to subject,type and specifies callback, userArg.
Definition at line 1800 of file cMsgWrapper.cc. |
|
Subscribes to subject/type, returns one matching message, then unsubscribes.
Definition at line 2106 of file cMsgWrapper.cc. |
|
Return the total number of messages passed to the given subscription's callback.
Definition at line 1998 of file cMsgWrapper.cc. |
|
Pause delivery of messages to the given subscription's callback.
Definition at line 1903 of file cMsgWrapper.cc. |
|
Clear all messages from the given subscription callback's queue.
Definition at line 1949 of file cMsgWrapper.cc. |
|
Return the number of messages currently in the given subscription callback's queue.
Definition at line 1973 of file cMsgWrapper.cc. |
|
Returns whether the given subscription callback's queue is full (true) or not.
Definition at line 2023 of file cMsgWrapper.cc. |
|
Resume delivery of messages to the given subscription's callback if paused.
Definition at line 1926 of file cMsgWrapper.cc. |
|
Synchronously sends message.
Definition at line 1779 of file cMsgWrapper.cc. |
|
Synchronously sends message.
Definition at line 1754 of file cMsgWrapper.cc. |
|
Unsubscribes.
Definition at line 1872 of file cMsgWrapper.cc. |