From 65f143f86bafce96ef7096b5c550e71679f62626 Mon Sep 17 00:00:00 2001 From: Wiebe Cazemier Date: Tue, 25 May 2021 16:26:18 +0200 Subject: [PATCH] Fix sending queued messages before conack --- mqttpacket.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/mqttpacket.cpp b/mqttpacket.cpp index 8b96993..d266dd9 100644 --- a/mqttpacket.cpp +++ b/mqttpacket.cpp @@ -327,13 +327,14 @@ void MqttPacket::handleConnect() if (accessGranted) { bool sessionPresent = protocolVersion >= ProtocolVersion::Mqtt311 && !clean_session && subscriptionStore->sessionPresent(client_id); - subscriptionStore->registerClientAndKickExistingOne(sender); sender->setAuthenticated(true); ConnAck connAck(ConnAckReturnCodes::Accepted, sessionPresent); MqttPacket response(connAck); sender->writeMqttPacket(response); logger->logf(LOG_NOTICE, "Client '%s' logged in successfully", sender->repr().c_str()); + + subscriptionStore->registerClientAndKickExistingOne(sender); } else { -- libgit2 0.21.4