PublicProjectLibrary/include/pahoc/mqtt_communication.h

#pragma once

#include <pcl/point_types.h>
#include <pcl/point_cloud.h>

#include "pahoc/mqtt_async.h"
#include "tool/log.hpp"

class Tof3DMqttAsyncClient : public MqttAsyncClient {
public:
    static Tof3DMqttAsyncClient *iter() {
        static Tof3DMqttAsyncClient *instance = nullptr;
        if (instance == nullptr) {
            instance = new Tof3DMqttAsyncClient();
        }
        return instance;
    }

    void init(const std::string &file);

protected:
    Tof3DMqttAsyncClient() = default;

private:
    void run();

    static int CloudDataArrived(MqttAsyncClient *client, char *topicName, int topicLen, MQTTAsync_message *message);

public:

private:
    std::mutex m_cloud_mutex;

};