From 3df5316ed1d6cbe61dbaf4e2f1855393b1096eec Mon Sep 17 00:00:00 2001
From: Michael Klishin <michael@clojurewerkz.org>
Date: Thu, 13 Jun 2019 16:55:16 +0300
Subject: [PATCH] Make default worker pool size configurable

Part of rabbitmq/rabbitmq-server#2030.
---
 priv/schema/rabbit.schema                     | 7 +++++++
 test/config_schema_SUITE_data/rabbit.snippets | 8 ++++++++
 2 files changed, 15 insertions(+)

diff --git a/priv/schema/rabbit.schema b/priv/schema/rabbit.schema
index c7171ce74a..44c199ff4d 100644
--- a/priv/schema/rabbit.schema
+++ b/priv/schema/rabbit.schema
@@ -391,6 +391,13 @@ end}.
     {datatype, integer}
 ]}.
 
+%% Default worker process pool size. Used to limit maximum concurrency rate
+%% of certain operations, e.g. queue initialisation and recovery on node boot.
+
+{mapping, "default_worker_pool_size", "rabbit.default_worker_pool_size", [
+    {datatype, integer}, {validators, ["non_negative_integer"]}
+]}.
+
 %% Password hashing implementation. Will only affect newly
 %% created users. To recalculate hash for an existing user
 %% it's necessary to update her password.
diff --git a/test/config_schema_SUITE_data/rabbit.snippets b/test/config_schema_SUITE_data/rabbit.snippets
index 9afddd9b1e..4e34738a60 100644
--- a/test/config_schema_SUITE_data/rabbit.snippets
+++ b/test/config_schema_SUITE_data/rabbit.snippets
@@ -566,6 +566,14 @@ credential_validator.regexp = ^abc\\d+",
   [{rabbit,[{log, [{categories, [{connection, [{file, "file_name_connection"}]},
                                  {channel, [{file, "file_name_channel"}]}]}]}]}],
   []},
+
+ {default_worker_pool_size,
+  "default_worker_pool_size = 512",
+  [{rabbit, [
+      {default_worker_pool_size, 512}
+    ]}],
+  []},
+
  {delegate_count,
   "delegate_count = 64",
   [{rabbit, [