Skip to content

Commit 1bdd460

Browse files
Log consumer timeout as a warning
1 parent c655cfc commit 1bdd460

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/rabbit_channel.erl

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2719,10 +2719,10 @@ evaluate_consumer_timeout(State0 = #ch{cfg = #conf{channel = Channel,
27192719
{value, {_DTag, ConsumerTag, Time, {_QPid, _Msg}}}
27202720
when is_integer(Timeout)
27212721
andalso Time < Now - Timeout ->
2722-
rabbit_log_channel:info("Consumer ~s on channel ~w has timed out "
2723-
"waiting on consumer acknowledgement. Timeout used: ~p ms",
2724-
[rabbit_data_coercion:to_binary(ConsumerTag),
2725-
Channel, Timeout]),
2722+
rabbit_log_channel:warning("Consumer ~s on channel ~w has timed out "
2723+
"waiting on consumer acknowledgement. Timeout used: ~p ms",
2724+
[rabbit_data_coercion:to_binary(ConsumerTag),
2725+
Channel, Timeout]),
27262726
Ex = rabbit_misc:amqp_error(precondition_failed,
27272727
"consumer ack timed out on channel ~w",
27282728
[Channel], none),

0 commit comments

Comments
 (0)