Publish our message
| 46 | |
| 47 | // Publish our message |
| 48 | void publishMessage() |
| 49 | { |
| 50 | if(mqtt.getConnectionState() != eTCS_Connected) { |
| 51 | startMqttClient(); // Auto reconnect |
| 52 | } |
| 53 | |
| 54 | Serial << _F("Let's publish message now. Memory free=") << system_get_free_heap_size() << endl; |
| 55 | mqtt.publish(F("main/frameworks/sming"), F("Hello friends, from Internet of things :)")); |
| 56 | |
| 57 | mqtt.publish(F("important/frameworks/sming"), F("Request Return Delivery"), |
| 58 | MqttClient::getFlags(MQTT_QOS_AT_LEAST_ONCE)); |
| 59 | } |
| 60 | |
| 61 | // Callback for messages, arrived from MQTT server |
| 62 | int onMessageReceived(MqttClient& client, mqtt_message_t* message) |
no test coverage detected