diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index ce0d695642..1429e0a8d0 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -394,7 +394,7 @@ init(QueueName, true, true) -> TRef), {DeltaCount, IndexState} = rabbit_queue_index:recover( - QueueName, Terms, + QueueName, Terms1, rabbit_msg_store:successfully_recovered_state(?PERSISTENT_MSG_STORE), fun (Guid) -> rabbit_msg_store:contains(Guid, PersistentClient) |