diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-12-04 16:48:34 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-12-04 16:48:34 +0000 |
| commit | e01cf9e2d7c60c640d138f8e3da1eb001d146813 (patch) | |
| tree | eccbf05f843be59383bda655d4e6afef39439641 /src | |
| parent | da01d7b96dc5ea124b40b3b00987105318276b0c (diff) | |
| download | rabbitmq-server-git-e01cf9e2d7c60c640d138f8e3da1eb001d146813.tar.gz | |
Don't leak on noack.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c703d3b934..f2fd0388af 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1239,9 +1239,10 @@ remove(AckRequired, MsgStatus = #msg_status { end, Ack = fun () -> rabbit_queue_index:ack([SeqId], IndexState1) end, IndexState2 = case {AckRequired, MsgInStore, IndexOnDisk} of - {false, true, false} -> Rem(), IndexState1; - {false, true, true} -> Rem(), Ack(); - _ -> IndexState1 + {false, true, false} -> Rem(), IndexState1; + {false, true, true} -> Rem(), Ack(); + {false, false, true} -> Ack(); + _ -> IndexState1 end, %% 3. If an ack is required, add something sensible to PA |