initialize @broekrs in server instead of in connection_factory

cloudamqp · Dec 13, 2024 · 2bbbcd9 · 2bbbcd9
1 parent 81ee5fd
commit 2bbbcd9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/lavinmq/mqtt/connection_factory.cr b/src/lavinmq/mqtt/connection_factory.cr
@@ -11,8 +11,8 @@ module LavinMQ
     class ConnectionFactory < LavinMQ::ConnectionFactory
       def initialize(@users : UserStore,
                      @vhosts : VHostStore,
+                     @brokers : Brokers,
                      replicator : Clustering::Replicator)
-        @brokers = Brokers.new(@vhosts, replicator)
       end
 
       def start(socket : ::IO, connection_info : ConnectionInfo)

diff --git a/src/lavinmq/server.cr b/src/lavinmq/server.cr
@@ -43,9 +43,10 @@ module LavinMQ
       Schema.migrate(@data_dir, @replicator)
       @users = UserStore.new(@data_dir, @replicator)
       @vhosts = VHostStore.new(@data_dir, @users, @replicator)
+      @brokers = MQTT::Brokers.new(@vhosts, @replicator)
       @parameters = ParameterStore(Parameter).new(@data_dir, "parameters.json", @replicator)
       @connection_factories[Protocol::AMQP] = AMQP::ConnectionFactory.new(@users, @vhosts)
-      @connection_factories[Protocol::MQTT] = MQTT::ConnectionFactory.new(@users, @vhosts, @replicator)
+      @connection_factories[Protocol::MQTT] = MQTT::ConnectionFactory.new(@users, @vhosts, @brokers, @replicator)
       apply_parameter
       spawn stats_loop, name: "Server#stats_loop"
     end