File tree Expand file tree Collapse file tree 1 file changed +0
-22
lines changed Expand file tree Collapse file tree 1 file changed +0
-22
lines changed Original file line number Diff line number Diff line change @@ -266,7 +266,6 @@ setup(_) ->
266266 RetryTimeout = retry_timeout (),
267267 case khepri_cluster :wait_for_leader (? STORE_ID , RetryTimeout ) of
268268 ok ->
269- wait_for_register_projections (),
270269 ? LOG_DEBUG (
271270 " Khepri-based " ? RA_FRIENDLY_NAME " ready" ,
272271 #{domain => ? RMQLOG_DOMAIN_GLOBAL }),
@@ -286,27 +285,6 @@ retry_timeout() ->
286285 undefined -> 30000
287286 end .
288287
289- retry_limit () ->
290- case application :get_env (rabbit , khepri_leader_wait_retry_limit ) of
291- {ok , T } -> T ;
292- undefined -> 10
293- end .
294-
295- wait_for_register_projections () ->
296- wait_for_register_projections (retry_timeout (), retry_limit ()).
297-
298- wait_for_register_projections (_Timeout , 0 ) ->
299- exit (timeout_waiting_for_khepri_projections );
300- wait_for_register_projections (Timeout , Retries ) ->
301- rabbit_log :info (" Waiting for Khepri projections for ~tp ms, ~tp retries left" ,
302- [Timeout , Retries - 1 ]),
303- case register_projections () of
304- ok ->
305- ok ;
306- {error , timeout } ->
307- wait_for_register_projections (Timeout , Retries - 1 )
308- end .
309-
310288% % @private
311289
312290-spec init () -> Ret when
You can’t perform that action at this time.
0 commit comments