diff options
Diffstat (limited to 'src')
| -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 a25245c98f..4effc65baf 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 |