root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 7 Packages Projects Releases Wiki Activity

Local shovels: skip tests in mixed-version (#14473) 

Local shovels require rabbitmq_4_0_0 feature flag, so it can't run
in mixed-version clusters with 3.13.x
This commit is contained in:
D Corbacho 2025-09-01 13:25:51 +02:00 committed by GitHub
parent 07ad94b269
commit 0977ad2dde
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 24 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
deps/rabbitmq_shovel/test/local_dynamic_SUITE.erl vendored
View File

@ -97,9 +97,17 @@ init_per_suite(Config0) ->
"dest_queue_down" "dest_queue_down"
]} ]}
]), ]),
rabbit_ct_helpers:run_setup_steps(Config1, Config2 = rabbit_ct_helpers:run_setup_steps(Config1,
rabbit_ct_broker_helpers:setup_steps() ++ rabbit_ct_broker_helpers:setup_steps() ++
rabbit_ct_client_helpers:setup_steps()). rabbit_ct_client_helpers:setup_steps()),
[Node] = rabbit_ct_broker_helpers:get_node_configs(Config2, nodename),
case rabbit_ct_broker_helpers:enable_feature_flag(
Config2, [Node], 'rabbitmq_4.0.0') of
ok ->
Config2;
_ ->
{skip, "This suite requires rabbitmq_4.0.0 feature flag"}
end.
end_per_suite(Config) -> end_per_suite(Config) ->
application:stop(amqp10_client), application:stop(amqp10_client),
@ -108,9 +116,6 @@ end_per_suite(Config) ->
rabbit_ct_broker_helpers:teardown_steps()). rabbit_ct_broker_helpers:teardown_steps()).
init_per_group(_, Config) -> init_per_group(_, Config) ->
[Node] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
ok = rabbit_ct_broker_helpers:enable_feature_flag(
Config, [Node], 'rabbitmq_4.0.0'),
Config. Config.
end_per_group(_, Config) -> end_per_group(_, Config) ->
@ -1033,7 +1038,6 @@ local_to_local_stream_credit_flow(Config, AckMode) ->
local_to_local_simple_uri(Config) -> local_to_local_simple_uri(Config) ->
Src = ?config(srcq, Config), Src = ?config(srcq, Config),
Dest = ?config(destq, Config), Dest = ?config(destq, Config),
AltVHost = ?config(alt_vhost, Config),
Uri = <<"amqp://">>, Uri = <<"amqp://">>,
ok = rabbit_ct_broker_helpers:rpc( ok = rabbit_ct_broker_helpers:rpc(
Config, 0, rabbit_runtime_parameters, set, Config, 0, rabbit_runtime_parameters, set,

17
deps/rabbitmq_shovel/test/local_static_SUITE.erl vendored
View File

@ -61,10 +61,19 @@ init_per_suite(Config) ->
"dest_queue_down" "dest_queue_down"
]} ]}
]), ]),
rabbit_ct_helpers:run_setup_steps(Config1, Config2 = rabbit_ct_helpers:run_setup_steps(
rabbit_ct_broker_helpers:setup_steps() ++ Config1,
rabbit_ct_client_helpers:setup_steps() ++ rabbit_ct_broker_helpers:setup_steps() ++
[fun stop_shovel_plugin/1]). rabbit_ct_client_helpers:setup_steps() ++
[fun stop_shovel_plugin/1]),
[Node] = rabbit_ct_broker_helpers:get_node_configs(Config2, nodename),
case rabbit_ct_broker_helpers:enable_feature_flag(
Config2, [Node], 'rabbitmq_4.0.0') of
ok ->
Config2;
_ ->
{skip, "This suite requires rabbitmq_4.0.0 feature flag"}
end.
end_per_suite(Config) -> end_per_suite(Config) ->
application:stop(amqp10_client), application:stop(amqp10_client),