don't break line limit with client init

cloudamqp · Jan 21, 2025 · 8cf1321 · 8cf1321
1 parent c14e65b
commit 8cf1321
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr
@@ -42,7 +42,14 @@ module LavinMQ
         if prev_client = @clients[packet.client_id]?
           prev_client.close("New client #{connection_info.src} (username=#{packet.username}) connected as #{packet.client_id}")
         end
-        client = MQTT::Client.new(socket, connection_info, user, self, packet.client_id, packet.clean_session?, packet.keepalive, packet.will)
+        client = MQTT::Client.new(socket,
+                                  connection_info,
+                                  user,
+                                  self,
+                                  packet.client_id,
+                                  packet.clean_session?,
+                                  packet.keepalive,
+                                  packet.will)
         if session = sessions[client.client_id]?
           if client.clean_session?
             sessions.delete session

diff --git a/src/lavinmq/mqtt/client.cr b/src/lavinmq/mqtt/client.cr
@@ -29,7 +29,7 @@ module LavinMQ
                      @user : User,
                      @broker : MQTT::Broker,
                      @client_id : String,
-                     @clean_session = false,
+                     @clean_session : Bool = false,
                      @keepalive : UInt16 = 30,
                      @will : MQTT::Will? = nil)
         @io = MQTT::IO.new(@socket)