From 4dc6eeb48507e4a9dac8b6ee45ce7916335d06e3 Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Wed, 18 Dec 2024 16:20:13 +0100 Subject: [PATCH] lint --- src/lavinmq/amqp/queue/stream_queue_message_store.cr | 6 +++--- src/lavinmq/amqp/stream_consumer.cr | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/lavinmq/amqp/queue/stream_queue_message_store.cr b/src/lavinmq/amqp/queue/stream_queue_message_store.cr index 3ede29651d..4819f9ff78 100644 --- a/src/lavinmq/amqp/queue/stream_queue_message_store.cr +++ b/src/lavinmq/amqp/queue/stream_queue_message_store.cr @@ -108,7 +108,7 @@ module LavinMQ::AMQP seg end - def shift?(consumer : AMQP::StreamConsumer) : Envelope? + def shift?(consumer : AMQP::StreamConsumer) : Envelope? # ameba:disable Metrics/CyclomaticComplexity raise ClosedError.new if @closed if env = shift_requeued(consumer.requeued) @@ -127,7 +127,7 @@ module LavinMQ::AMQP consumer.pos += sp.bytesize consumer.offset += 1 if consumer_filter = consumer.filter # can be a string or an array of comma-separated strings - return unless matching?(msg.properties.headers, consumer_filter, consumer.match_unfiltered) + return unless matching?(msg.properties.headers, consumer_filter, consumer.match_unfiltered?) end Envelope.new(sp, msg, redelivered: false) rescue ex @@ -136,7 +136,7 @@ module LavinMQ::AMQP end private def matching?(msg_headers, consumer_filter, match_unfiltered) : Bool - if (msg_filters = filter_values_from_headers(msg_headers)) + if msg_filters = filter_values_from_headers(msg_headers) consumer_filter.split(",").each do |filter| return true if msg_filters == filter end diff --git a/src/lavinmq/amqp/stream_consumer.cr b/src/lavinmq/amqp/stream_consumer.cr index beb59d2cc1..0058b743c3 100644 --- a/src/lavinmq/amqp/stream_consumer.cr +++ b/src/lavinmq/amqp/stream_consumer.cr @@ -10,7 +10,7 @@ module LavinMQ property pos : UInt32 getter requeued = Deque(SegmentPosition).new getter filter : String? - getter match_unfiltered : Bool = false + getter? match_unfiltered : Bool = false def initialize(@channel : Client::Channel, @queue : StreamQueue, frame : AMQP::Frame::Basic::Consume) validate_preconditions(frame)