ZeroMQ.hpp

Go to the documentation of this file.

#pragma once
 
#include <zmq.hpp>
 
class ZeroMQ {
  private:
    // Internal context
    std::shared_ptr<zmq::context_t> _contextPtr;
    // Internal socket
    std::unique_ptr<zmq::socket_t> _socketPtr;
 
    // Is currently active
    bool _isActive{false};
    // Should be binded
    bool _isBinded{false};
    // Address to bind/connect
    std::string _socketAddr;
 
    // Initializes class
    void init(const std::shared_ptr<zmq::context_t> &ctx, const zmq::socket_type &type, const std::string_view &addr,
              bool isBind);
 
  public:
    ZeroMQ(const zmq::socket_type &type, const std::string &addr, bool isBind);
 
    ZeroMQ(const std::shared_ptr<zmq::context_t> &ctx, const zmq::socket_type &type, const std::string &addr,
           bool isBind);
 
    ZeroMQ(const ZeroMQ & /*unused*/) = delete;
 
    ZeroMQ(ZeroMQ && /*unused*/) = delete;
 
    ZeroMQ &operator=(ZeroMQ /*unused*/) = delete;
 
    ZeroMQ &operator=(ZeroMQ && /*unused*/) = delete;
 
    bool start();
 
    void stop();
 
    std::vector<zmq::message_t> recvMessages();
 
    size_t sendMessages(std::vector<zmq::message_t> &msg);
 
    [[nodiscard]] const std::unique_ptr<zmq::socket_t> &getSocket() const { return _socketPtr; }
 
    [[nodiscard]] const std::shared_ptr<zmq::context_t> &getContext() const { return _contextPtr; }
 
    [[nodiscard]] const std::string &getAddress() const { return _socketAddr; }
 
    ~ZeroMQ();
};