ETM-Schurig
/
nymea-mqtt
mirror of https://github.com/nymea/nymea-mqtt
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Start keep alive timer before emitting connected() 

By chaning the order MqttClient::isConnected() returns true
in slot connected to MqttClient::connected().
unit-test-for-connected
Timon 2021-02-04 13:27:10 +01:00
parent 718a495437
commit 5eebdf75f7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libnymea-mqtt/mqttclient.cpp
View File

@ -364,9 +364,9 @@ void MqttClientPrivate::onReadyRead()
} }
socket->write(retryPacket.serialize()); socket->write(retryPacket.serialize());
} }
restartKeepAliveTimer();
// Make sure we emit connected after having handled all the retransmission queue // Make sure we emit connected after having handled all the retransmission queue
emit q_ptr->connected(packet.connectReturnCode(), packet.connackFlags()); emit q_ptr->connected(packet.connectReturnCode(), packet.connackFlags());
restartKeepAliveTimer();
break; break;
case MqttPacket::TypePublish: case MqttPacket::TypePublish:
qCDebug(dbgClient) << "Publish received from server. Topic:" << packet.topic() << "Payload:" << packet.payload() << "QoS:" << packet.qos(); qCDebug(dbgClient) << "Publish received from server. Topic:" << packet.topic() << "Payload:" << packet.payload() << "QoS:" << packet.qos();