refactor

Co-authored-by: Jon Börjesson <jon@84codes.com>
cloudamqp · Jan 10, 2025 · fdfb99b · fdfb99b
1 parent d47f57f
commit fdfb99b
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/lavinmq/amqp/queue/stream_queue_message_store.cr b/src/lavinmq/amqp/queue/stream_queue_message_store.cr
@@ -137,9 +137,7 @@ module LavinMQ::AMQP
 
       private def matching?(msg_headers, consumer_filter, match_unfiltered) : Bool
         if msg_filter = filter_value_from_headers(msg_headers)
-          consumer_filter.each do |filter|
-            return true if msg_filter == filter
-          end
+            return consumer_filter.includes? msg_filter
         else
           return match_unfiltered
         end