client.hpp

Go to the documentation of this file.

#ifndef ZIO_DOMO_CLIENT_HPP_SEEND
#define ZIO_DOMO_CLIENT_HPP_SEEND

#include "zio/util.hpp"

namespace zio {
namespace domo {

    class Client {
    public:
        Client(zio::socket_t& sock, std::string broker_address);

        ~Client();

        // API methods

        void send(std::string service, zio::multipart_t& request);

        void recv(zio::multipart_t& reply);

    private:
        zio::socket_t& m_sock;
        std::string m_address;
        time_unit_t m_timeout{HEARTBEAT_INTERVAL};
        
    private:
        std::function<void(zio::socket_t& server_socket,
                           zio::multipart_t& mmsg)> really_recv;
        std::function<void(zio::socket_t& server_socket,
                           zio::multipart_t& mmsg)> really_send;

        void connect_to_broker(bool reconnect = true);
    };
}
}
#endif