Skip to content

Commit d3919de

Browse files
committed
rabbit_khepri: Remove projection registration from setup/0
1 parent 937af18 commit d3919de

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,6 @@ setup(_) ->
265265
case khepri:start(?RA_SYSTEM, RaServerConfig) of
266266
{ok, ?STORE_ID} ->
267267
wait_for_leader(),
268-
wait_for_register_projections(),
269268
?LOG_DEBUG(
270269
"Khepri-based " ?RA_FRIENDLY_NAME " ready",
271270
#{domain => ?RMQLOG_DOMAIN_GLOBAL}),
@@ -308,24 +307,6 @@ wait_for_leader(Timeout, Retries) ->
308307
throw(Reason)
309308
end.
310309

311-
-spec wait_for_register_projections() -> Ret when
312-
Ret :: ok | no_return().
313-
314-
wait_for_register_projections() ->
315-
wait_for_register_projections(retry_timeout(), retry_limit()).
316-
317-
wait_for_register_projections(_Timeout, 0) ->
318-
exit(timeout_waiting_for_khepri_projections);
319-
wait_for_register_projections(Timeout, Retries) ->
320-
rabbit_log:info("Waiting for Khepri projections for ~tp ms, ~tp retries left",
321-
[Timeout, Retries - 1]),
322-
case register_projections() of
323-
ok ->
324-
ok;
325-
{error, timeout} ->
326-
wait_for_register_projections(Timeout, Retries -1)
327-
end.
328-
329310
%% @private
330311

331312
can_join_cluster(DiscoveryNode) when is_atom(DiscoveryNode) ->

0 commit comments

Comments
 (0)