diff --git a/src/lavinmq/config.cr b/src/lavinmq/config.cr index 6b4f6258e4..152290557d 100644 --- 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 index fde1fb6b11..c971ee98b8 100644 --- 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"