From 7208650262a6b7a9fae76326ffd83e6a9b102d5d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Christina=20Dahl=C3=A9n?= <85930202+kickster97@users.noreply.github.com> Date: Fri, 24 Jan 2025 12:48:33 +0100 Subject: [PATCH] Update src/lavinmq/mqtt/broker.cr MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Carl Hörberg --- src/lavinmq/mqtt/broker.cr | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr index e2bbda21ad..ee50ef0408 100644 --- 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