Skip to content

Commit b89cea1

Browse files
When consumer hits an ack timeout, log timeout value used
1 parent 3a60faf commit b89cea1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/rabbit_channel.erl

Lines changed: 3 additions & 3 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 ack",
2722+
rabbit_log_channel:info("Consumer ~s on channel ~w has timed out "
2723+
"waiting on consumer acknowledgement. Timeout used: ~p ms",
27242724
[rabbit_data_coercion:to_binary(ConsumerTag),
2725-
Channel]),
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)