From 2da02b9a5186f2e8a889e44e570556de7721a697 Mon Sep 17 00:00:00 2001
From: Christina <christina@84codes.com>
Date: Thu, 23 Jan 2025 13:21:57 +0100
Subject: [PATCH] for specs, re-init connection factory for server restart

---
 src/lavinmq/server.cr | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/lavinmq/server.cr b/src/lavinmq/server.cr
index 4d9379180b..6a7dcf1d90 100644
--- a/src/lavinmq/server.cr
+++ b/src/lavinmq/server.cr
@@ -66,6 +66,7 @@ module LavinMQ
       @users = UserStore.new(@data_dir, @replicator)
       @vhosts = VHostStore.new(@data_dir, @users, @replicator)
       @parameters = ParameterStore(Parameter).new(@data_dir, "parameters.json", @replicator)
+      @amqp_connection_factory = LavinMQ::AMQP::ConnectionFactory.new(@users, @vhosts)
       apply_parameter
       @closed = false
       Fiber.yield