for specs, re-init connection factory for server restart

cloudamqp · Jan 23, 2025 · 2da02b9 · 2da02b9
1 parent 0e2291b
commit 2da02b9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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