diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-04-10 11:58:37 +0200 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-04-10 11:58:37 +0200 |
| commit | 5c3d2648abaedc18e36f2ba99bd70aec0df3b1be (patch) | |
| tree | a9da05140e527f8ef7d1647e6b9a0e7d215057d4 /src/OutputZeroMQ.h | |
| parent | c126ec3bfc44ab62017e7a75a1a1f49855f46f9a (diff) | |
| download | dabmod-5c3d2648abaedc18e36f2ba99bd70aec0df3b1be.tar.gz dabmod-5c3d2648abaedc18e36f2ba99bd70aec0df3b1be.tar.bz2 dabmod-5c3d2648abaedc18e36f2ba99bd70aec0df3b1be.zip | |
ZMQ output: Add REP socket type
Diffstat (limited to 'src/OutputZeroMQ.h')
| -rw-r--r-- | src/OutputZeroMQ.h | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/OutputZeroMQ.h b/src/OutputZeroMQ.h index a80eab4..85f85a7 100644 --- a/src/OutputZeroMQ.h +++ b/src/OutputZeroMQ.h @@ -39,14 +39,15 @@ class OutputZeroMQ : public ModOutput { public: - OutputZeroMQ(std::string endpoint, Buffer* dataOut = NULL); + OutputZeroMQ(std::string endpoint, int type, Buffer* dataOut = NULL); virtual ~OutputZeroMQ(); virtual int process(Buffer* dataIn, Buffer* dataOut); const char* name() { return m_name.c_str(); } protected: + int m_type; // zmq socket type zmq::context_t m_zmq_context; // handle for the zmq context - zmq::socket_t m_zmq_pub_sock; // handle for the zmq publisher socket + zmq::socket_t m_zmq_sock; // handle for the zmq publisher socket std::string m_endpoint; // On which port to listen: e.g. // tcp://*:58300 |