Skip to content

Commit 27621c5

Browse files
committed
Add schema tests
1 parent 78d80ec commit 27621c5

File tree

2 files changed

+60
-4
lines changed

2 files changed

+60
-4
lines changed

deps/rabbit/priv/schema/rabbit.schema

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2669,11 +2669,23 @@ end}.
26692669
{mapping, "message_interceptors.outgoing.$interceptor.enabled", "rabbit.outgoing_message_interceptors", [
26702670
{datatype, {enum, [true]}}]}.
26712671

2672-
{mapping, "message_interceptors.incoming.set_header_timestamp.overwrite", "rabbit.incoming_message_interceptors", [
2673-
{datatype, {enum, [true, false]}}]}.
2672+
{mapping,
2673+
"message_interceptors.incoming.set_header_timestamp.overwrite",
2674+
"rabbit.incoming_message_interceptors",
2675+
[{datatype, {enum, [true, false]}}]}.
2676+
{mapping,
2677+
"message_interceptors.incoming.rabbit_message_interceptor_routing_node.overwrite",
2678+
"rabbit.incoming_message_interceptors",
2679+
[{datatype, {enum, [true, false]}}]}.
26742680

2675-
{mapping, "message_interceptors.incoming.set_header_routing_node.overwrite", "rabbit.incoming_message_interceptors", [
2676-
{datatype, {enum, [true, false]}}]}.
2681+
{mapping,
2682+
"message_interceptors.incoming.set_header_routing_node.overwrite",
2683+
"rabbit.incoming_message_interceptors",
2684+
[{datatype, {enum, [true, false]}}]}.
2685+
{mapping,
2686+
"message_interceptors.incoming.rabbit_message_interceptor_timestamp.overwrite",
2687+
"rabbit.incoming_message_interceptors",
2688+
[{datatype, {enum, [true, false]}}]}.
26772689

26782690
{translation, "rabbit.incoming_message_interceptors",
26792691
fun(Conf) ->

deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets

Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1119,6 +1119,50 @@ credential_validator.regexp = ^abc\\d+",
11191119
]}],
11201120
[]},
11211121

1122+
% Enable key allows to configure interceptors with empty conf
1123+
{message_interceptors,
1124+
"
1125+
message_interceptors.incoming.set_header_routing_node.enabled = true
1126+
",
1127+
[{rabbit, [
1128+
{incoming_message_interceptors, [
1129+
{rabbit_message_interceptor_routing_node, #{}}
1130+
]}
1131+
]}],
1132+
[]},
1133+
1134+
% An interceptor can be configured twice, with different options, both in
1135+
% incoming and outgoing group of interceptors
1136+
{message_interceptors,
1137+
"
1138+
message_interceptors.incoming.rabbit_message_interceptor_routing_node.overwrite = true
1139+
message_interceptors.outgoing.rabbit_message_interceptor_routing_node.enabled = true
1140+
",
1141+
[{rabbit, [
1142+
{incoming_message_interceptors, [
1143+
{rabbit_message_interceptor_routing_node, #{overwrite => true}}
1144+
]},
1145+
{outgoing_message_interceptors, [
1146+
{rabbit_message_interceptor_routing_node, #{}}
1147+
]}
1148+
]}],
1149+
[]},
1150+
1151+
% Given a parameter gets configured multiple times, last value prevails
1152+
{message_interceptors,
1153+
"
1154+
message_interceptors.incoming.set_header_routing_node.overwrite = true
1155+
message_interceptors.incoming.set_header_routing_node.overwrite = false
1156+
message_interceptors.incoming.set_header_routing_node.overwrite = true
1157+
message_interceptors.incoming.set_header_routing_node.overwrite = false
1158+
",
1159+
[{rabbit, [
1160+
{incoming_message_interceptors, [
1161+
{rabbit_message_interceptor_routing_node, #{overwrite => false}}
1162+
]}
1163+
]}],
1164+
[]},
1165+
11221166
%%
11231167
%% Stream replication port range
11241168
%%

0 commit comments

Comments
 (0)