Skip to content

Commit 3234d8d

Browse files
committed
rabbit_khepri: Unregister all projections when enabling khepri_db ff
1 parent 99df61f commit 3234d8d

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1095,6 +1095,12 @@ collect_payloads(Props, Acc0) when is_map(Props) andalso is_list(Acc0) ->
10951095
Acc
10961096
end, Acc0, Props).
10971097

1098+
-spec unregister_all_projections() -> Ret when
1099+
Ret :: ok | timeout_error().
1100+
1101+
unregister_all_projections() ->
1102+
khepri:unregister_projections(?STORE_ID, all).
1103+
10981104
register_projections() ->
10991105
RegFuns = [fun register_rabbit_exchange_projection/0,
11001106
fun register_rabbit_queue_projection/0,
@@ -1507,6 +1513,7 @@ get_feature_state(Node) ->
15071513
khepri_db_migration_enable(#{feature_name := FeatureName}) ->
15081514
maybe
15091515
ok ?= sync_cluster_membership_from_mnesia(FeatureName),
1516+
ok ?= unregister_all_projections(),
15101517
ok ?= register_projections(),
15111518
migrate_mnesia_tables(FeatureName)
15121519
end.

0 commit comments

Comments
 (0)