MqttMessaging.h

Go to the documentation of this file.

#pragma once

#include "JsonUtils.h"
#include "IMessaging.h"
#include <string>

class MqttMessagingImpl;

typedef std::basic_string<unsigned char> ustring;

class MqttMessaging : public IMessaging
{
public:
  MqttMessaging() = delete;
  MqttMessaging(const std::string& name);

  virtual ~MqttMessaging();

  void start() override;
  void stop() override;
  void update(const rapidjson::Value& cfg) override;
  const std::string& getName() const override;
  void registerMessageHandler(MessageHandlerFunc hndl) override;
  void unregisterMessageHandler() override;
  void sendMessage(const ustring& msg) override;

private:
  MqttMessagingImpl* m_impl;
};