Update src/lavinmq/mqtt/broker.cr

Co-authored-by: Carl Hörberg <[email protected]>
cloudamqp · Jan 24, 2025 · 7208650 · 7208650
1 parent 01edef9
commit 7208650
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr
@@ -26,7 +26,7 @@ module LavinMQ
       def initialize(@vhost : VHost, @replicator : Clustering::Replicator)
         @sessions = Sessions.new(@vhost)
         @clients = Hash(String, Client).new
-        @retain_store = RetainStore.new(File.join(@vhost.data_dir, "mqtt_reatined_store"), @replicator)
+        @retain_store = RetainStore.new(File.join(@vhost.data_dir, "mqtt_retained_store"), @replicator)
         @exchange = MQTT::Exchange.new(@vhost, EXCHANGE, @retain_store)
         @vhost.exchanges[EXCHANGE] = @exchange
       end