Skip to content

Commit

Permalink
Mention delivery ack timeout configurability
Browse files Browse the repository at this point in the history
in the logs and consumer channel error message.

References #2990, #3032.
  • Loading branch information
michaelklishin committed May 11, 2021
1 parent 682b09c commit 6cd4d62
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions deps/rabbit/src/rabbit_channel.erl
Original file line number Diff line number Diff line change
Expand Up @@ -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}
Expand Down

0 comments on commit 6cd4d62

Please sign in to comment.