format

cloudamqp · Jan 13, 2025 · 150c2f7 · 150c2f7
1 parent 0e7e2cf
commit 150c2f7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/lavinmq/amqp/queue/stream_queue_message_store.cr b/src/lavinmq/amqp/queue/stream_queue_message_store.cr
@@ -137,7 +137,7 @@ module LavinMQ::AMQP
 
       private def matching?(msg_headers, consumer_filter, match_unfiltered) : Bool
         if msg_filter = filter_value_from_headers(msg_headers)
-            return consumer_filter.includes? msg_filter
+          return consumer_filter.includes? msg_filter
         else
           return match_unfiltered
         end