diff options
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index e7f7fa1902..28d0b47dd6 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -244,7 +244,7 @@ shutdown_terms(Name) -> {error, _} -> []; {ok, Terms1} -> Terms1 end. - + recover(Name, Terms, MsgStoreRecovered, ContainsCheckFun) -> State = #qistate { dir = Dir } = blank_state(Name), CleanShutdown = detect_clean_shutdown(Dir), diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 7ac6ea9980..ce0d695642 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -396,7 +396,7 @@ init(QueueName, true, true) -> rabbit_queue_index:recover( QueueName, Terms, rabbit_msg_store:successfully_recovered_state(?PERSISTENT_MSG_STORE), - fun (Guid) -> + fun (Guid) -> rabbit_msg_store:contains(Guid, PersistentClient) end), init(true, IndexState, DeltaCount, Terms1, |