CMqttMessage.hpp

Go to the documentation of this file.

#ifndef C_MQTT_MESSAGE_HPP
#define C_MQTT_MESSAGE_HPP

#include <string>

#include <MQTTClient.h>
#include <boost/shared_ptr.hpp>

namespace freedm {
namespace broker {
namespace device {

class CMqttMessage
{
public:
    typedef boost::shared_ptr<CMqttMessage> Pointer;

    static Pointer Create(std::string topic, std::string content, int qos = 1);

    const MQTTClient_deliveryToken & GetToken() const;

    void Publish(MQTTClient client);

    ~CMqttMessage();
private:
    CMqttMessage(std::string topic, std::string content, int qos);

    char * m_Payload;

    std::string m_Topic;

    MQTTClient_message m_Message;

    MQTTClient_deliveryToken m_Token;
};

} //namespace device
} //namespace broker
} //namespace freedm

#endif // C_MQTT_MESSAGE_HPP