diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-10-17 19:09:39 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-10-17 19:09:39 +0100 |
| commit | b37f5fdd8b1d3e06df69023be28c6fa6cccd2b8f (patch) | |
| tree | 9ac30f1dd06af6de9ea961106a51d8cf4d28a62a /src/rabbit_msg_store.erl | |
| parent | 87c472085297325d9558757732100e4510607ae3 (diff) | |
| download | rabbitmq-server-b37f5fdd8b1d3e06df69023be28c6fa6cccd2b8f.tar.gz | |
fix bug
Diffstat (limited to 'src/rabbit_msg_store.erl')
| -rw-r--r-- | src/rabbit_msg_store.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index a25245c9..4effc65b 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -825,7 +825,7 @@ handle_cast({remove, CRef, MsgIds}, State) -> lists:foldl( fun (MsgId, {Removed, State2}) -> case update_flying(+1, MsgId, CRef, State2) of - process -> {[MsgId, Removed], + process -> {[MsgId | Removed], remove_message(MsgId, CRef, State2)}; ignore -> {Removed, State2} end |