Skip to content

Commit dee4a3e

Browse files
Merge pull request #10977 from rabbitmq/mergify/bp/v3.13.x/pr-10976
changed log line to allow for MaxConsumers being an integer not a string (backport #10976)
2 parents 3112f15 + 76051e0 commit dee4a3e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

deps/rabbit/src/rabbit_channel.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1366,7 +1366,7 @@ handle_method(#'basic.consume'{queue = <<"amq.rabbitmq.reply-to">>,
13661366
case maps:find(CTag0, ConsumerMapping) of
13671367
error when CurrentConsumers >= MaxConsumers -> % false when MaxConsumers is 'infinity'
13681368
rabbit_misc:protocol_error(
1369-
not_allowed, "reached maximum (~ts) of consumers per channel", [MaxConsumers]);
1369+
not_allowed, "reached maximum (~B) of consumers per channel", [MaxConsumers]);
13701370
error ->
13711371
case {ReplyConsumer, NoAck} of
13721372
{none, true} ->
@@ -1425,7 +1425,7 @@ handle_method(#'basic.consume'{queue = QueueNameBin,
14251425
case maps:find(ConsumerTag, ConsumerMapping) of
14261426
error when CurrentConsumers >= MaxConsumers -> % false when MaxConsumers is 'infinity'
14271427
rabbit_misc:protocol_error(
1428-
not_allowed, "reached maximum (~ts) of consumers per channel", [MaxConsumers]);
1428+
not_allowed, "reached maximum (~B) of consumers per channel", [MaxConsumers]);
14291429
error ->
14301430
QueueName = qbin_to_resource(QueueNameBin, VHostPath),
14311431
check_read_permitted(QueueName, User, AuthzContext),

0 commit comments

Comments
 (0)