Make queue migration batch size configurable

Daniil Fedotov · Daniil Fedotov · commit b57483d54aba · 2016-11-30T12:19:44.000Z
diff --git 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),
 
