diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-05-03 13:25:49 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-05-03 13:25:49 +0300 |
| commit | 1bdd460e60d758412ef2a5dc9d3861136e05833f (patch) | |
| tree | c855c5cfe7b06fb05ba6d55ba15f7e640548e03d | |
| parent | c655cfc0d87eb52ba28703be569ba4f74540d7aa (diff) | |
| download | rabbitmq-server-git-1bdd460e60d758412ef2a5dc9d3861136e05833f.tar.gz | |
Log consumer timeout as a warning
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index b75b101d1e..19d4449e21 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 consumer acknowledgement. Timeout used: ~p ms", - [rabbit_data_coercion:to_binary(ConsumerTag), - Channel, Timeout]), + rabbit_log_channel:warning("Consumer ~s on channel ~w has timed out " + "waiting on consumer acknowledgement. Timeout used: ~p ms", + [rabbit_data_coercion:to_binary(ConsumerTag), + Channel, Timeout]), Ex = rabbit_misc:amqp_error(precondition_failed, "consumer ack timed out on channel ~w", [Channel], none), |