diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-07-23 16:20:17 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-07-23 16:20:17 +0100 |
| commit | 003ef115e3aeecc9465992e27c1f0b1544791eea (patch) | |
| tree | dcbdee99159a10c785fb60dac39a19d25a55173e /src/rabbit_amqqueue_process.erl | |
| parent | 9fb2f35c1afa4c911850edcb2adf6f8e55e7f666 (diff) | |
| download | rabbitmq-server-003ef115e3aeecc9465992e27c1f0b1544791eea.tar.gz | |
First pass at queue-size-in-bytes. Only lightly tested, and with no upgrade step for QI. But I wanted to commit something...
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 4082c53d..04a38b78 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -665,9 +665,12 @@ subtract_acks(ChPid, AckTags, State = #q{consumers = Consumers}, Fun) -> run_message_queue(true, Fun(State1)) end. -message_properties(Message, Confirm, #q{ttl = TTL}) -> +message_properties(Message = #basic_message{content = Content}, + Confirm, #q{ttl = TTL}) -> + #content{payload_fragments_rev = PFR} = Content, #message_properties{expiry = calculate_msg_expiry(Message, TTL), - needs_confirming = Confirm == eventually}. + needs_confirming = Confirm == eventually, + size = iolist_size(PFR)}. calculate_msg_expiry(#basic_message{content = Content}, TTL) -> #content{properties = Props} = |