DelegateMQ
|
ZeroMQ transport example. Each Transport object must only be called by a single thread of control per ZeroMQ library. More...
#include <ZeroMqTransport.h>
Public Types | |
enum class | Type { PAIR_CLIENT , PAIR_SERVER , PUB , SUB } |
Public Member Functions | |
int | Create (Type type, const char *addr) |
void | Close () |
void | Destroy () |
virtual int | Send (xostringstream &os, const DmqHeader &header) override |
virtual xstringstream | Receive (DmqHeader &header) override |
void | SetTransportMonitor (ITransportMonitor *transportMonitor) |
![]() |
ZeroMQ transport example. Each Transport object must only be called by a single thread of control per ZeroMQ library.
|
strong |
|
inline |
|
inline |
|
inline |
|
inlineoverridevirtual |
Receive data from a remote
[out] | header | Incoming delegate message header. |
Implements ITransport.
|
inlineoverridevirtual |
Send data to a remote
[in] | os | Output stream to send. |
[in] | header | The header to send. |
Implements ITransport.
|
inline |