@@ -1036,24 +1036,20 @@ share_dist_and_proxy_ports_map(Config) ->
1036
1036
configured_metadata_store (Config ) ->
1037
1037
case rabbit_ct_helpers :get_config (Config , metadata_store ) of
1038
1038
khepri ->
1039
- {khepri , []};
1040
- {khepri , _FFs0 } = Khepri ->
1041
- Khepri ;
1039
+ khepri ;
1042
1040
mnesia ->
1043
1041
mnesia ;
1044
1042
_ ->
1045
1043
case os :getenv (" RABBITMQ_METADATA_STORE" ) of
1046
- " khepri" ->
1047
- {khepri , []};
1048
- _ ->
1049
- mnesia
1044
+ " khepri" -> khepri ;
1045
+ _ -> mnesia
1050
1046
end
1051
1047
end .
1052
1048
1053
1049
configure_metadata_store (Config ) ->
1054
1050
ct :log (" Configuring metadata store..." ),
1055
1051
Value = rabbit_ct_helpers :get_app_env (
1056
- Config , rabbit , forced_feature_flags_on_init , undefined ),
1052
+ Config , rabbit , forced_feature_flags_on_init , undefined ),
1057
1053
MetadataStore = configured_metadata_store (Config ),
1058
1054
Config1 = rabbit_ct_helpers :set_config (
1059
1055
Config , {metadata_store , MetadataStore }),
@@ -1070,32 +1066,32 @@ configure_metadata_store(Config) ->
1070
1066
case Value of
1071
1067
undefined ->
1072
1068
rabbit_ct_helpers :merge_app_env (
1073
- Config1 ,
1074
- {rabbit ,
1075
- [{forced_feature_flags_on_init ,
1076
- {rel , [khepri_db ], []}}]});
1069
+ Config1 ,
1070
+ {rabbit ,
1071
+ [{forced_feature_flags_on_init ,
1072
+ {rel , [khepri_db ], []}}]});
1077
1073
_ ->
1078
1074
rabbit_ct_helpers :merge_app_env (
1079
- Config1 ,
1080
- {rabbit ,
1081
- [{forced_feature_flags_on_init ,
1082
- [khepri_db | Value ]}]})
1075
+ Config1 ,
1076
+ {rabbit ,
1077
+ [{forced_feature_flags_on_init ,
1078
+ [khepri_db | Value ]}]})
1083
1079
end ;
1084
1080
mnesia ->
1085
1081
ct :log (" Enabling Mnesia metadata store" ),
1086
1082
case Value of
1087
1083
undefined ->
1088
1084
rabbit_ct_helpers :merge_app_env (
1089
- Config1 ,
1090
- {rabbit ,
1091
- [{forced_feature_flags_on_init ,
1092
- {rel , [], [khepri_db ]}}]});
1085
+ Config1 ,
1086
+ {rabbit ,
1087
+ [{forced_feature_flags_on_init ,
1088
+ {rel , [], [khepri_db ]}}]});
1093
1089
_ ->
1094
1090
rabbit_ct_helpers :merge_app_env (
1095
- Config1 ,
1096
- {rabbit ,
1097
- [{forced_feature_flags_on_init ,
1098
- Value -- [khepri_db ]}]})
1091
+ Config1 ,
1092
+ {rabbit ,
1093
+ [{forced_feature_flags_on_init ,
1094
+ Value -- [khepri_db ]}]})
1099
1095
end
1100
1096
end .
1101
1097
0 commit comments