mqttclient.cpp: unsubcribe & keepalive

This commit is contained in:
cyberman54 2020-12-31 17:47:48 +01:00
parent 4093a39e09
commit 2d2a8abd79

View File

@ -12,6 +12,7 @@ WiFiClient netClient;
MQTTClient mqttClient;
void mqtt_deinit(void) {
mqttClient.unsubscribe(MQTT_INTOPIC);
mqttClient.onMessageAdvanced(NULL);
mqttClient.disconnect();
vTaskDelete(mqttTask);
@ -22,6 +23,7 @@ esp_err_t mqtt_init(void) {
// setup network connection and MQTT client
ETH.begin();
mqttClient.begin(MQTT_SERVER, MQTT_PORT, netClient);
mqttClient.setKeepAlive(MQTT_KEEPALIVE);
mqttClient.onMessageAdvanced(mqtt_callback);
_ASSERT(SEND_QUEUE_SIZE > 0);