mqtt_adapter_if.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
 
#include "spsp/mqtt_types.hpp"
 
namespace SPSP::FarLayers::MQTT
{
    class AdapterError : public SPSP::Exception
    {
        using SPSP::Exception::Exception;
    };
 
    // Callback types
    using AdapterConnectedCb = std::function<void()>;
    using AdapterSubDataCb = std::function<void(const std::string& topic,
                                                const std::string& payload)>;
 
    class IAdapter
    {
    public:
        virtual bool publish(const std::string& topic, const std::string& payload) = 0;
 
        virtual bool subscribe(const std::string& topic) = 0;
 
        virtual bool unsubscribe(const std::string& topic) = 0;
 
        virtual void setSubDataCb(AdapterSubDataCb cb) = 0;
 
        virtual void setConnectedCb(AdapterConnectedCb cb) = 0;
    };
} // namespace SPSP::FarLayers::MQTT