From 150c2f786c3ac80e23129cdcab97b7aaa49ba95a Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Mon, 13 Jan 2025 10:10:42 +0100 Subject: [PATCH] format --- src/lavinmq/amqp/queue/stream_queue_message_store.cr | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/lavinmq/amqp/queue/stream_queue_message_store.cr b/src/lavinmq/amqp/queue/stream_queue_message_store.cr index 51c3a1fce6..1361d19272 100644 --- 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