diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2010-11-11 18:44:41 +0000 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2010-11-11 18:44:41 +0000 |
| commit | fe630f2e0e3512489c65ecd1aae853e509885490 (patch) | |
| tree | cfd153e6a08a00d5b898e2f9e5b48a071f823af5 | |
| parent | 22a941d8d369d058beb2e3245a562e73cb9efe06 (diff) | |
| download | rabbitmq-server-git-fe630f2e0e3512489c65ecd1aae853e509885490.tar.gz | |
Added assertion in limit_ram_acks for is_persistent=false
| -rw-r--r-- | src/rabbit_variable_queue.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 9c25540eda..6f8fd3bcc7 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1437,8 +1437,9 @@ limit_ram_acks(Quota, State = #vqstate { pending_ack = PA, false -> {SeqId, Guid, RAI1} = gb_trees:take_largest(RAI), MsgStatus = #msg_status { - guid = Guid, %% ASSERTION - msg_props = MsgProps } = dict:fetch(SeqId, PA), + guid = Guid, %% ASSERTION + is_persistent = false, %% ASSERTION + msg_props = MsgProps } = dict:fetch(SeqId, PA), {_, State1} = maybe_write_to_disk(true, false, MsgStatus, State), limit_ram_acks(Quota - 1, State1 #vqstate { |