format

cloudamqp · Jan 2, 2025 · 66aa10f · 66aa10f
1 parent d1e3c2a
commit 66aa10f
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/src/lavinmq/config.cr b/src/lavinmq/config.cr
@@ -42,7 +42,6 @@ module LavinMQ
     property? set_timestamp = false             # in message headers when receive
     property socket_buffer_size = 16384         # bytes
     property? tcp_nodelay = false               # bool
-    property max_inflight_messages : UInt16 = 65_535
     property segment_size : Int32 = 8 * 1024**2 # bytes
     property max_inflight_messages : UInt16 = 65_535
     property? raise_gc_warn : Bool = false

diff --git a/src/lavinmq/server.cr b/src/lavinmq/server.cr
@@ -48,7 +48,7 @@ module LavinMQ
       @parameters = ParameterStore(Parameter).new(@data_dir, "parameters.json", @replicator)
       @connection_factories = {
         Protocol::AMQP => AMQP::ConnectionFactory.new(@users, @vhosts),
-        Protocol::MQTT => MQTT::ConnectionFactory.new(@users, @brokers)
+        Protocol::MQTT => MQTT::ConnectionFactory.new(@users, @brokers),
       }
       apply_parameter
       spawn stats_loop, name: "Server#stats_loop"