only send in client_id when unsubscribing a session

cloudamqp · Jan 27, 2025 · d8c1f3a · d8c1f3a
1 parent b555e93
commit d8c1f3a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr
@@ -92,8 +92,8 @@ module LavinMQ
         qos
       end
 
-      def unsubscribe(client, packet)
-        session = sessions[client.client_id]
+      def unsubscribe(client_id, packet)
+        session = sessions[client_id]
         packet.topics.each do |tf|
           session.unsubscribe(tf)
         end

diff --git a/src/lavinmq/mqtt/client.cr b/src/lavinmq/mqtt/client.cr
@@ -128,7 +128,7 @@ module LavinMQ
       end
 
       def recieve_unsubscribe(packet : MQTT::Unsubscribe)
-        @broker.unsubscribe(self, packet)
+        @broker.unsubscribe(self.client_id, packet)
         send(MQTT::UnsubAck.new(packet.packet_id))
       end