Class MqttSubscriber¶

Defined in File mqtt_subscriber.h

Inheritance Relationships¶

Base Type¶

public mqtt::callback

Class Documentation¶

class MqttSubscriber : public virtual mqtt::callback¶

Public Functions

MqttSubscriber(const std::string &server, const std::string &topic)¶

~MqttSubscriber() override¶

inline std::string topic() const noexcept¶

void connect()¶

std::optional<std::string> poll(std::chrono::milliseconds timeout = std::chrono::milliseconds(1000))¶

std::optional<std::string> read(std::chrono::milliseconds timeout = std::chrono::milliseconds::zero())¶

void message_arrived(mqtt::const_message_ptr msg) override¶