diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 7cebf2b1bf..9a8cb86e90 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -725,7 +725,7 @@ remove_pending_ack(KeepPersistent, rabbit_misc:dict_cons( ?TRANSIENT_MSG_STORE, Guid, Dict)} end; - (_SeqId, #basic_message {}, Acc) -> + (_SeqId, #msg_status {}, Acc) -> Acc end, {[], dict:new()}, PA), case KeepPersistent of @@ -735,7 +735,7 @@ remove_pending_ack(KeepPersistent, pending_ack = dict:filter( fun (_SeqId, {IsPersistent, _Guid}) -> IsPersistent; - (_SeqId, #basic_message {}) -> false + (_SeqId, #msg_status {}) -> false end, PA) }, case dict:find(?TRANSIENT_MSG_STORE, GuidsByStore) of error -> State1; |