Skip to content

Commit ca69084

Browse files
Merge pull request #10976 from cloudamqp/fix_consumer_max_per_channel_logging
changed log line to allow for MaxConsumers being an integer not a string
2 parents 60513d1 + 8392bde commit ca69084

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
@@ -1323,7 +1323,7 @@ handle_method(#'basic.consume'{queue = <<"amq.rabbitmq.reply-to">>,
13231323
case maps:find(CTag0, ConsumerMapping) of
13241324
error when CurrentConsumers >= MaxConsumers -> % false when MaxConsumers is 'infinity'
13251325
rabbit_misc:protocol_error(
1326-
not_allowed, "reached maximum (~ts) of consumers per channel", [MaxConsumers]);
1326+
not_allowed, "reached maximum (~B) of consumers per channel", [MaxConsumers]);
13271327
error ->
13281328
case {ReplyConsumer, NoAck} of
13291329
{none, true} ->
@@ -1382,7 +1382,7 @@ handle_method(#'basic.consume'{queue = QueueNameBin,
13821382
case maps:find(ConsumerTag, ConsumerMapping) of
13831383
error when CurrentConsumers >= MaxConsumers -> % false when MaxConsumers is 'infinity'
13841384
rabbit_misc:protocol_error(
1385-
not_allowed, "reached maximum (~ts) of consumers per channel", [MaxConsumers]);
1385+
not_allowed, "reached maximum (~B) of consumers per channel", [MaxConsumers]);
13861386
error ->
13871387
QueueName = qbin_to_resource(QueueNameBin, VHostPath),
13881388
check_read_permitted(QueueName, User, AuthzContext),

0 commit comments

Comments
 (0)