From ddabc3519117c1556ef1a5467931242d07e5f425 Mon Sep 17 00:00:00 2001 From: David Ansari Date: Mon, 15 May 2023 10:06:01 +0000 Subject: Change rabbitmq.conf key to message_interceptors.incoming.* as it nicer categorises if there will be a future "message_interceptors.outgoing.*" key. We leave the advanced config file key because simple single value settings should not require using the advanced config file. --- deps/rabbit/priv/schema/rabbit.schema | 6 +++--- deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) (limited to 'deps') diff --git a/deps/rabbit/priv/schema/rabbit.schema b/deps/rabbit/priv/schema/rabbit.schema index e8226ab4e8..7c8b627e9c 100644 --- a/deps/rabbit/priv/schema/rabbit.schema +++ b/deps/rabbit/priv/schema/rabbit.schema @@ -2507,12 +2507,12 @@ end}. %% %% Message interceptors %% -{mapping, "incoming_message_interceptors.$interceptor.overwrite", "rabbit.incoming_message_interceptors", [ +{mapping, "message_interceptors.incoming.$interceptor.overwrite", "rabbit.incoming_message_interceptors", [ {datatype, {enum, [true, false]}}]}. {translation, "rabbit.incoming_message_interceptors", fun(Conf) -> - case cuttlefish_variable:filter_by_prefix("incoming_message_interceptors", Conf) of + case cuttlefish_variable:filter_by_prefix("message_interceptors", Conf) of [] -> cuttlefish:unset(); L -> @@ -2525,7 +2525,7 @@ end}. false -> cuttlefish:invalid(io_lib:format("~p is invalid", [Interceptor])) end - end || {["incoming_message_interceptors", Interceptor0, "overwrite"], Overwrite} <- L] + end || {["message_interceptors", "incoming", Interceptor0, "overwrite"], Overwrite} <- L] end end }. diff --git a/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets b/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets index 2e6fae9aa5..b387befeee 100644 --- a/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets +++ b/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets @@ -932,7 +932,7 @@ credential_validator.regexp = ^abc\\d+", %% {message_interceptors, - "incoming_message_interceptors.set_header_timestamp.overwrite = true", + "message_interceptors.incoming.set_header_timestamp.overwrite = true", [{rabbit, [ {incoming_message_interceptors, [{set_header_timestamp, true}]} ]}], @@ -940,8 +940,8 @@ credential_validator.regexp = ^abc\\d+", {message_interceptors, " - incoming_message_interceptors.set_header_routing_node.overwrite = false - incoming_message_interceptors.set_header_timestamp.overwrite = false + message_interceptors.incoming.set_header_routing_node.overwrite = false + message_interceptors.incoming.set_header_timestamp.overwrite = false ", [{rabbit, [ {incoming_message_interceptors, [{set_header_routing_node, false}, -- cgit v1.2.1