Add delegate_count to Cuttlefish schema

Closes #1497.

[#154982180]

2 files changed, 16 insertions, 0 deletions

diff --git a/priv/schema/rabbit.schema b/priv/schema/rabbit.schema
index 9bff18d75d..a39e47f7af 100644
--- a/priv/schema/rabbit.schema
+++ b/priv/schema/rabbit.schema
@@ -546,6 +546,7 @@ end}.
  end
 }.
 
+
 %% Customising Socket Options.
 %%
 %% See (http://www.erlang.org/doc/man/inet.html#setopts-2) for
@@ -801,6 +802,15 @@ fun(Conf) ->
     end
 end}.
 
+%% Number of delegate processes to use for intra-cluster
+%% communication. On a machine which has a very large number of cores
+%% and is also part of a cluster, you may wish to increase this value.
+%%
+
+{mapping, "delegate_count", "rabbit.delegate_count", [
+    {datatype, integer}, {validators, ["non_negative_integer"]}
+]}.
+
 %% Mirror sync batch size, in messages. Increasing this will speed
 %% up syncing but total batch size in bytes must not exceed 2 GiB.
 %% Available in RabbitMQ 3.6.0 or later.
diff --git a/test/config_schema_SUITE_data/rabbit.snippets b/test/config_schema_SUITE_data/rabbit.snippets
index 51a59c3a31..d8b43c7fb8 100644
--- a/test/config_schema_SUITE_data/rabbit.snippets
+++ b/test/config_schema_SUITE_data/rabbit.snippets
@@ -522,5 +522,11 @@ credential_validator.regexp = ^abc\\d+",
    log.channel.file = file_name_channel",
   [{rabbit,[{log, [{categories, [{connection, [{file, "file_name_connection"}]},
                                  {channel, [{file, "file_name_channel"}]}]}]}]}],
+  []},
+ {delegate_count,
+  "delegate_count = 64",
+  [{rabbit, [
+      {delegate_count, 64}
+    ]}],
   []}
 ].