diff options
| author | dcorbacho <dparracorbac@vmware.com> | 2022-07-06 13:45:18 +0200 |
|---|---|---|
| committer | dcorbacho <dparracorbac@vmware.com> | 2022-07-06 13:45:18 +0200 |
| commit | 605dcb755a22d623d207abcc3c6bc1c2609e9858 (patch) | |
| tree | 2fe31bdac3ab2de6b72957d1640c50b19cf314f9 | |
| parent | f91548d382e068f326ba7d27ce272e745305add9 (diff) | |
| download | rabbitmq-server-git-use-khepri-metadata-store.tar.gz | |
Feature flags: use ffcommand when calling raft based metadata store migration functionuse-khepri-metadata-store
| -rw-r--r-- | deps/rabbit/src/rabbit_core_ff.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/deps/rabbit/src/rabbit_core_ff.erl b/deps/rabbit/src/rabbit_core_ff.erl index b3a44bb49f..6e6a74cab1 100644 --- a/deps/rabbit/src/rabbit_core_ff.erl +++ b/deps/rabbit/src/rabbit_core_ff.erl @@ -13,8 +13,9 @@ -include_lib("rabbit_common/include/rabbit.hrl"). -include_lib("rabbit_common/include/logging.hrl"). --include("vhost.hrl"). +-include("feature_flags.hrl"). -include("internal_user.hrl"). +-include("vhost.hrl"). -export([quorum_queue_migration/3, implicit_default_bindings_migration/3, @@ -303,7 +304,7 @@ direct_exchange_routing_v2_migration(_FeatureName, _FeatureProps, is_enabled) -> rabbit_topic_permission, rabbit_runtime_parameters]). -mds_phase1_migration(#{name := FeatureName, command := enable}) -> +mds_phase1_migration(#ffcommand{name = FeatureName, command = enable}) -> case ensure_khepri_cluster_matches_mnesia(FeatureName) of ok -> Tables = ?MDS_PHASE1_TABLES, @@ -314,7 +315,7 @@ mds_phase1_migration(#{name := FeatureName, command := enable}) -> Error -> Error end; -mds_phase1_migration(#{name := FeatureName, command := post_enable}) -> +mds_phase1_migration(#ffcommand{name = FeatureName, command = post_enable}) -> ?assert(rabbit_khepri:is_enabled(non_blocking)), Tables = ?MDS_PHASE1_TABLES, empty_unused_mnesia_tables(FeatureName, Tables). |