diff options
| -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, |