lint

cloudamqp · Apr 22, 2024 · ce1d73b · ce1d73b
1 parent ee24d4e
commit ce1d73b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lavinmq/queue/stream_queue_message_store.cr b/src/lavinmq/queue/stream_queue_message_store.cr
@@ -160,10 +160,10 @@ module LavinMQ
       end
 
       def remove_consumer_tag_from_file(consumer_tag)
-        @consumer_offset_positions = consumer_offset_positions.reject! { |k, v| k == consumer_tag }
+        @consumer_offset_positions = consumer_offset_positions.reject! { |k, _v| k == consumer_tag }
 
         offsets_to_save = Hash(String, Int64).new
-        consumer_offset_positions.each do |ctag, pos|
+        consumer_offset_positions.each do |ctag, _p|
           offset = last_offset_by_consumer_tag(ctag)
           next unless offset
           offsets_to_save[ctag] = offset