cleanup

cloudamqp · Oct 21, 2024 · 7cfbfa1 · 7cfbfa1
1 parent 5b05ff1
commit 7cfbfa1
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr
@@ -106,8 +106,6 @@ module LavinMQ
         packet.topic_filters.each do |tf|
           qos << MQTT::SubAck::ReturnCode.from_int(tf.qos)
           session.subscribe(tf.topic, tf.qos)
-
-          #Publish retained messages
           @retain_store.each(tf.topic) do |topic, body|
             rk = topicfilter_to_routingkey(topic)
             msg = Message.new("mqtt.default", rk, String.new(body),