diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-05-03 13:19:37 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-05-03 13:19:37 +0300 |
| commit | b89cea1e569de387243b31d6900bb95da3aab03b (patch) | |
| tree | 3dee1349332d68454729aca424ae0fa734bc6a26 | |
| parent | 3a60fafb0892378d83d2181b1aa7e312f214544f (diff) | |
| download | rabbitmq-server-git-b89cea1e569de387243b31d6900bb95da3aab03b.tar.gz | |
When consumer hits an ack timeout, log timeout value used
| -rw-r--r-- | src/rabbit_channel.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index cfc3e3ab1f..b75b101d1e 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -2719,10 +2719,10 @@ evaluate_consumer_timeout(State0 = #ch{cfg = #conf{channel = Channel, {value, {_DTag, ConsumerTag, Time, {_QPid, _Msg}}} when is_integer(Timeout) andalso Time < Now - Timeout -> - rabbit_log_channel:info("Consumer ~s on Channel ~w has timed out " - "waiting on ack", + rabbit_log_channel:info("Consumer ~s on channel ~w has timed out " + "waiting on consumer acknowledgement. Timeout used: ~p ms", [rabbit_data_coercion:to_binary(ConsumerTag), - Channel]), + Channel, Timeout]), Ex = rabbit_misc:amqp_error(precondition_failed, "consumer ack timed out on channel ~w", [Channel], none), |