Middlewares-Linux/CallOut/MqttTask.h

#pragma once
#include <memory>
#include <thread>

#include "MQTTAsyncPublish.h"

class MqttTask
{
public:
	MqttTask();
	~MqttTask();

	bool Conn(const std::string&strServerUrl, const std::string&strClientId, const std::string&strTopic);

	void Run();

private:
	void onMqttMsg(const string& topic, const string& msg);

private:
	std::unique_ptr<MQTTAsyncPublish>  pMqtt;
	std::unique_ptr<std::thread>  pListenThread;
	bool m_bStopThread;

	std::string m_startTime;
	std::string m_endTime;
};