diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-10-06 17:51:53 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-10-06 17:51:53 +0100 |
| commit | 5760b4ef12634123b0b568c36105e0368e6caeb2 (patch) | |
| tree | afe5155d3b6326860fbfc54a8560a7693f056bed /src/rabbit_channel.erl | |
| parent | 9b1cf9ba35cdc21c6f9a0dd175e9d9ca526c798d (diff) | |
| download | rabbitmq-server-5760b4ef12634123b0b568c36105e0368e6caeb2.tar.gz | |
Rename function, and GC for large messages on the way out, too.bug25850
Diffstat (limited to 'src/rabbit_channel.erl')
| -rw-r--r-- | src/rabbit_channel.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 7f10c19f..8632e1b3 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -375,6 +375,7 @@ handle_cast({deliver, ConsumerTag, AckRequired, exchange = ExchangeName#resource.name, routing_key = RoutingKey}, Content), + rabbit_basic:maybe_gc_large_msg(Content), noreply(record_sent(ConsumerTag, AckRequired, Msg, State)); handle_cast({deliver_reply, _K, _Del}, State = #ch{state = closing}) -> @@ -607,7 +608,7 @@ check_internal_exchange(_) -> ok. check_msg_size(Content) -> - Size = rabbit_basic:msg_size_and_gc(Content), + Size = rabbit_basic:maybe_gc_large_msg(Content), case Size > ?MAX_MSG_SIZE of true -> precondition_failed("message size ~B larger than max size ~B", [Size, ?MAX_MSG_SIZE]); |