diff options
| -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 9b3cc58aaa..abad3adb21 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -624,8 +624,9 @@ ack(AckTags, State) -> {Guids, State1} = ack(fun msg_store_remove/3, fun ({_IsPersistent, Guid, _MsgProps}, State1) -> - remove_confirms(gb_sets:singleton(Guid), State1), - State1 + remove_confirms(gb_sets:singleton(Guid), State1); + (#msg_status{msg = #basic_message{guid = Guid}}, State1) -> + remove_confirms(gb_sets:singleton(Guid), State1) end, AckTags, State), {Guids, a(State1)}. |