DelegateMQ
Loading...
Searching...
No Matches
ZeroMqTransport Class Reference

ZeroMQ transport example. Each Transport object must only be called by a single thread of control per ZeroMQ library. More...

#include <ZeroMqTransport.h>

Inheritance diagram for ZeroMqTransport:
ITransport

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)
 
- Public Member Functions inherited from ITransport

Detailed Description

ZeroMQ transport example. Each Transport object must only be called by a single thread of control per ZeroMQ library.

Member Enumeration Documentation

◆ Type

enum class ZeroMqTransport::Type
strong
Enumerator
PAIR_CLIENT 
PAIR_SERVER 
PUB 
SUB 

Member Function Documentation

◆ Close()

void ZeroMqTransport::Close ( )
inline

◆ Create()

int ZeroMqTransport::Create ( Type type,
const char * addr )
inline

◆ Destroy()

void ZeroMqTransport::Destroy ( )
inline

◆ Receive()

virtual xstringstream ZeroMqTransport::Receive ( DmqHeader & header)
inlineoverridevirtual

Receive data from a remote

Parameters
[out]headerIncoming delegate message header.
Returns
The received incoming data bytes, not including the header.

Implements ITransport.

◆ Send()

virtual int ZeroMqTransport::Send ( xostringstream & os,
const DmqHeader & header )
inlineoverridevirtual

Send data to a remote

Parameters
[in]osOutput stream to send.
[in]headerThe header to send.
Returns
0 if success.

Implements ITransport.

◆ SetTransportMonitor()

void ZeroMqTransport::SetTransportMonitor ( ITransportMonitor * transportMonitor)
inline

The documentation for this class was generated from the following file: