diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index ca8c92b80e..9dcb2eef82 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -2732,7 +2732,9 @@ move_messages_to_vhost_store() -> OldStore = run_old_persistent_store(RecoveryRefs, StartFunState), %% New store should not be recovered. NewStoreSup = start_new_store_sup(), - in_batches(?QUEUE_MIGRATION_BATCH_SIZE, + MigrationBatchSize = application:get_env(rabbit, queue_migration_batch_size, + ?QUEUE_MIGRATION_BATCH_SIZE), + in_batches(MigrationBatchSize, {rabbit_variable_queue, migrate_queue, [OldStore, NewStoreSup]}, QueuesWithTerms), |