Skip to content

Commit 7c8cc61

Browse files
committed
rabbit_khepri: Use ?STORE_ID for projection registration functions
This is a cosmetic change. `?RA_CLUSTER_NAME` is equivalent but is used for clustering commands. Commands sent via the `khepri`/`khepri_adv` APIs consistently use the `?STORE_ID` macro instead.
1 parent 3e42bd5 commit 7c8cc61

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1192,7 +1192,7 @@ register_rabbit_user_permissions_projection() ->
11921192
register_simple_projection(Name, PathPattern, KeyPos) ->
11931193
Options = #{keypos => KeyPos},
11941194
Projection = khepri_projection:new(Name, copy, Options),
1195-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1195+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11961196

11971197
register_rabbit_bindings_projection() ->
11981198
MapFun = fun(_Path, Binding) ->
@@ -1208,7 +1208,7 @@ register_rabbit_bindings_projection() ->
12081208
_Kind = ?KHEPRI_WILDCARD_STAR,
12091209
_DstName = ?KHEPRI_WILDCARD_STAR,
12101210
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1211-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1211+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
12121212

12131213
register_rabbit_index_route_projection() ->
12141214
MapFun = fun(Path, _) ->
@@ -1240,7 +1240,7 @@ register_rabbit_index_route_projection() ->
12401240
_Kind = ?KHEPRI_WILDCARD_STAR,
12411241
_DstName = ?KHEPRI_WILDCARD_STAR,
12421242
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1243-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1243+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
12441244

12451245
%% Routing information is stored in the Khepri store as a `set'.
12461246
%% In order to turn these bindings into records in an ETS `bag', we use a
@@ -1341,7 +1341,7 @@ register_rabbit_topic_graph_projection() ->
13411341
_Kind = ?KHEPRI_WILDCARD_STAR,
13421342
_DstName = ?KHEPRI_WILDCARD_STAR,
13431343
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1344-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1344+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
13451345

13461346
-spec follow_down_update(Table, Exchange, Words, UpdateFn) -> Ret when
13471347
Table :: ets:tid(),

0 commit comments

Comments
 (0)