broker_connect.h

#ifndef RECODEX_BROKER_BROKER_HPP
#define RECODEX_BROKER_BROKER_HPP


#include "config/broker_config.h"
#include "handlers/broker_handler.h"
#include "handlers/status_notifier_handler.h"
#include "helpers/logger.h"
#include "notifier/empty_status_notifier.h"
#include "notifier/status_notifier.h"
#include "reactor/command_holder.h"
#include "reactor/reactor.h"
#include "reactor/router_socket_wrapper.h"
#include "worker_registry.h"
#include <chrono>
#include <memory>

class broker_connect
{
private:
    std::shared_ptr<const broker_config> config_;
    std::shared_ptr<spdlog::logger> logger_;
    std::shared_ptr<worker_registry> workers_;
    reactor reactor_;

public:
    const static std::string KEY_WORKERS;

    const static std::string KEY_CLIENTS;

    const static std::string KEY_MONITOR;

    const static std::string KEY_STATUS_NOTIFIER;

    const static std::string KEY_TIMER;

    const static std::string MONITOR_IDENTITY;

    broker_connect(std::shared_ptr<const broker_config> config,
        std::shared_ptr<zmq::context_t> context,
        std::shared_ptr<worker_registry> router,
        std::shared_ptr<spdlog::logger> logger = nullptr);

    void start_brokering();
};


#endif // RECODEX_BROKER_BROKER_HPP