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 | b4ce991122d79a1b25de0f5bdd3f50af6fa0b032 (patch) | |
| tree | cfd153e6a08a00d5b898e2f9e5b48a071f823af5 | |
| parent | 8fbc7073556c0718562a70245c65644cea01e3f9 (diff) | |
| download | rabbitmq-server-b4ce991122d79a1b25de0f5bdd3f50af6fa0b032.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 9c25540e..6f8fd3bc 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 { |