From 7cfbfa10ffa94efadfe3d7f7c2d311963c09010f Mon Sep 17 00:00:00 2001 From: Christina Date: Mon, 21 Oct 2024 13:12:04 +0200 Subject: [PATCH] cleanup --- src/lavinmq/mqtt/broker.cr | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr index 693b6936dc..5417bf98f5 100644 --- 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),