|
DelegateMQ
|
NNG transport class. More...
#include <NngTransport.h>
Public Types | |
| enum class | Type { PAIR_CLIENT , PAIR_SERVER , PUB , SUB } |
Public Member Functions | |
| NngTransport () | |
| ~NngTransport () | |
| int | Create (Type type, const char *addr) |
| void | Close () |
| void | Destroy () |
| virtual int | Send (xostringstream &os, const DmqHeader &header) override |
| virtual int | Receive (xstringstream &is, DmqHeader &header) override |
| void | SetTransportMonitor (ITransportMonitor *transportMonitor) |
| void | SetSendTransport (ITransport *sendTransport) |
| void | SetRecvTransport (ITransport *recvTransport) |
Public Member Functions inherited from ITransport | |
NNG transport class.
Logic now executes directly on the caller's thread, protected by a mutex to prevent concurrent access to the underlying NNG socket.
|
strong |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inlineoverridevirtual |
Receive data from a remote
| [out] | is | The received incoming data bytes, not including the header. |
| [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 |
|
inline |
|
inline |