diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-12-29 19:59:00 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-12-29 19:59:00 +0300 |
| commit | fccc939ca7ec035ec43cbefedd2203e91fd7b2c7 (patch) | |
| tree | d062cbd934eb25e88ffab1a67030b53f865c5e71 | |
| parent | 999483872eeda4cd84ebfd5dbb21b2ee4cff93c1 (diff) | |
| download | rabbitmq-server-git-fccc939ca7ec035ec43cbefedd2203e91fd7b2c7.tar.gz | |
Reformatted #2197 by @nyczol, references #2199
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 5f6a3fd71d..4fd218754d 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -2708,7 +2708,10 @@ handle_deliver(ConsumerTag, AckRequired, false -> ok = rabbit_writer:send_command(WriterPid, Deliver, Content) end, - rabbit_basic:maybe_gc_large_msg(Content, GCThreshold), + case GCThreshold of + undefined -> ok; + _ -> rabbit_basic:maybe_gc_large_msg(Content, GCThreshold) + end, record_sent(deliver, ConsumerTag, AckRequired, Msg, State). handle_basic_get(WriterPid, DeliveryTag, NoAck, MessageCount, |