Skip to content

Commit 6cd4d62

Browse files
Mention delivery ack timeout configurability
in the logs and consumer channel error message. References #2990, #3032.
1 parent 682b09c commit 6cd4d62

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

deps/rabbit/src/rabbit_channel.erl

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2731,12 +2731,15 @@ evaluate_consumer_timeout(State0 = #ch{cfg = #conf{channel = Channel,
27312731
when is_integer(Timeout)
27322732
andalso Time < Now - Timeout ->
27332733
rabbit_log_channel:warning("Consumer ~s on channel ~w has timed out "
2734-
"waiting on consumer acknowledgement. Timeout used: ~p ms",
2734+
"waiting for delivery acknowledgement. Timeout used: ~p ms. "
2735+
"This timeout value can be configured, see consumers doc guide to learn more",
27352736
[rabbit_data_coercion:to_binary(ConsumerTag),
27362737
Channel, Timeout]),
27372738
Ex = rabbit_misc:amqp_error(precondition_failed,
2738-
"consumer ack timed out on channel ~w",
2739-
[Channel], none),
2739+
"delivery acknowledgement on channel ~w timed out. "
2740+
"Timeout value used: ~p ms. "
2741+
"This timeout value can be configured, see consumers doc guide to learn more",
2742+
[Channel, Timeout], none),
27402743
handle_exception(Ex, State0);
27412744
_ ->
27422745
{noreply, State0}

0 commit comments

Comments
 (0)