diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-08-11 16:12:58 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-08-11 16:12:58 +0100 |
| commit | 015ea854138f8a1eb7b2bd16b5a5594c08207c4a (patch) | |
| tree | b91efaafa840dc44f3620e9c484bce789774411f | |
| parent | fdade51d3cb749633fb944827f383c830d995b49 (diff) | |
| download | rabbitmq-server-git-015ea854138f8a1eb7b2bd16b5a5594c08207c4a.tar.gz | |
Oops
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 0fb2aa121a..c52862ab96 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1354,8 +1354,7 @@ remove_pending_ack(true, SeqId, State) -> remove_pending_ack(false, SeqId, State), PCount1 = PCount - one_if(MsgStatus#msg_status.is_persistent), {MsgStatus, upd_bytes(-1, MsgStatus, - State1 # vqstate{ persistent_count = PCount1 })}. - + State1 # vqstate{ persistent_count = PCount1 })}; remove_pending_ack(false, SeqId, State = #vqstate { ram_pending_ack = RPA, disk_pending_ack = DPA }) -> case gb_trees:lookup(SeqId, RPA) of |