BeeeOn Gateway
v2020.3.1-2-g6f737dc
Platform to interconnect the IoT world
|
IQRFMqttConnector provides sending and receiving messages. During data receiving, it is necessary to know identification of JSON message (GlobalID). The identification of message is used to bring sent and received message together. More...
#include <IQRFMqttConnector.h>
Public Types | |
typedef Poco::SharedPtr < IQRFMqttConnector > | Ptr |
Public Types inherited from BeeeOn::StoppableRunnable | |
typedef Poco::SharedPtr < StoppableRunnable > | Ptr |
Public Member Functions | |
void | run () override |
void | stop () override |
void | setPublishTopic (const std::string &topic) |
void | setMqttClient (MqttClient::Ptr mqttClient) |
void | setDataTimeout (const Poco::Timespan &timeout) |
void | setReceiveTimeout (const Poco::Timespan &timeout) |
void | checkPublishTopic () |
void | send (const std::string &msg) |
Send message using mqtt client to specific topic. | |
IQRFJsonResponse::Ptr | receive (const GlobalID &id, const Poco::Timespan &timeout) |
Receive message with given timeout and identification of message. | |
IQRFMqttConnector provides sending and receiving messages. During data receiving, it is necessary to know identification of JSON message (GlobalID). The identification of message is used to bring sent and received message together.
|
overridevirtual |
Stop the runnable. The call should not block.
Implements BeeeOn::StoppableRunnable.