From 6cd4d62cefccaff8355cf373b2091ebd7a5ab0a1 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Tue, 11 May 2021 23:13:59 +0300 Subject: [PATCH] Mention delivery ack timeout configurability in the logs and consumer channel error message. References #2990, #3032. --- deps/rabbit/src/rabbit_channel.erl | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/deps/rabbit/src/rabbit_channel.erl b/deps/rabbit/src/rabbit_channel.erl index 6d4d793c3884..065df1718b6c 100644 --- a/deps/rabbit/src/rabbit_channel.erl +++ b/deps/rabbit/src/rabbit_channel.erl @@ -2731,12 +2731,15 @@ evaluate_consumer_timeout(State0 = #ch{cfg = #conf{channel = Channel, when is_integer(Timeout) andalso Time < Now - Timeout -> rabbit_log_channel:warning("Consumer ~s on channel ~w has timed out " - "waiting on consumer acknowledgement. Timeout used: ~p ms", + "waiting for delivery acknowledgement. Timeout used: ~p ms. " + "This timeout value can be configured, see consumers doc guide to learn more", [rabbit_data_coercion:to_binary(ConsumerTag), Channel, Timeout]), Ex = rabbit_misc:amqp_error(precondition_failed, - "consumer ack timed out on channel ~w", - [Channel], none), + "delivery acknowledgement on channel ~w timed out. " + "Timeout value used: ~p ms. " + "This timeout value can be configured, see consumers doc guide to learn more", + [Channel, Timeout], none), handle_exception(Ex, State0); _ -> {noreply, State0}