From 76051e08986632be13d200d2b3744ceae93e9eee Mon Sep 17 00:00:00 2001 From: markus812498 Date: Fri, 12 Apr 2024 09:42:33 +1200 Subject: [PATCH] changed log line to allow for MaxConsumer being an integer not a string (cherry picked from commit 8392bdeef75ee74e8845aa885d1c79f4ec528c54) --- deps/rabbit/src/rabbit_channel.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/deps/rabbit/src/rabbit_channel.erl b/deps/rabbit/src/rabbit_channel.erl index ce445be264ed..c986594ffb9d 100644 --- a/deps/rabbit/src/rabbit_channel.erl +++ b/deps/rabbit/src/rabbit_channel.erl @@ -1366,7 +1366,7 @@ handle_method(#'basic.consume'{queue = <<"amq.rabbitmq.reply-to">>, case maps:find(CTag0, ConsumerMapping) of error when CurrentConsumers >= MaxConsumers -> % false when MaxConsumers is 'infinity' rabbit_misc:protocol_error( - not_allowed, "reached maximum (~ts) of consumers per channel", [MaxConsumers]); + not_allowed, "reached maximum (~B) of consumers per channel", [MaxConsumers]); error -> case {ReplyConsumer, NoAck} of {none, true} -> @@ -1425,7 +1425,7 @@ handle_method(#'basic.consume'{queue = QueueNameBin, case maps:find(ConsumerTag, ConsumerMapping) of error when CurrentConsumers >= MaxConsumers -> % false when MaxConsumers is 'infinity' rabbit_misc:protocol_error( - not_allowed, "reached maximum (~ts) of consumers per channel", [MaxConsumers]); + not_allowed, "reached maximum (~B) of consumers per channel", [MaxConsumers]); error -> QueueName = qbin_to_resource(QueueNameBin, VHostPath), check_read_permitted(QueueName, User, AuthzContext),