Commit 6081679bdbe39dd0243528af4c4a50d33ac93799
1 parent
aa8e1665
Fix sending wrong downgraded QoS retained messages
Showing
1 changed file
with
1 additions
and
1 deletions
subscriptionstore.cpp
| @@ -423,9 +423,9 @@ uint64_t SubscriptionStore::giveClientRetainedMessages(const std::shared_ptr<Ses | @@ -423,9 +423,9 @@ uint64_t SubscriptionStore::giveClientRetainedMessages(const std::shared_ptr<Ses | ||
| 423 | giveClientRetainedMessagesRecursively(subscribeSubtopics.begin(), subscribeSubtopics.end(), startNode, false, packetList); | 423 | giveClientRetainedMessagesRecursively(subscribeSubtopics.begin(), subscribeSubtopics.end(), startNode, false, packetList); |
| 424 | } | 424 | } |
| 425 | 425 | ||
| 426 | - std::shared_ptr<MqttPacket> possibleQos0Copy; | ||
| 427 | for(MqttPacket &packet : packetList) | 426 | for(MqttPacket &packet : packetList) |
| 428 | { | 427 | { |
| 428 | + std::shared_ptr<MqttPacket> possibleQos0Copy; | ||
| 429 | ses->writePacket(packet, max_qos, possibleQos0Copy, count); | 429 | ses->writePacket(packet, max_qos, possibleQos0Copy, count); |
| 430 | } | 430 | } |
| 431 | 431 |