disconnect old client completely

src/lavinmq/mqtt/broker.cr

@@ -41,7 +41,7 @@ module LavinMQ
       def connect_client(socket, connection_info, user, packet)
         if prev_client = @clients[packet.client_id]?
           Log.trace { "Found previous client connected with client_id: #{packet.client_id}, closing" }
-          prev_client.close
+          disconnect_client(prev_client)
         end
         client = MQTT::Client.new(socket, connection_info, user, @vhost, self, packet.client_id, packet.clean_session?, packet.will)
         if session = sessions[client.client_id]?
@@ -62,6 +62,7 @@ module LavinMQ
           sessions.delete(client_id) if session.clean_session?
         end
         @clients.delete client_id
+        client.close
         vhost.rm_connection(client)
       end