Skip to content

Commit dbc1756

Browse files
committed
Compile errors
1 parent 2808ba4 commit dbc1756

File tree

1 file changed

+1
-17
lines changed

1 file changed

+1
-17
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 1 addition & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -465,30 +465,14 @@ cli_cluster_status() ->
465465
end.
466466

467467
%% For when Khepri is enabled
468-
init_cluster(ClusterNodes) ->
468+
init_cluster(_ClusterNodes) ->
469469
%% Ensure the local Khepri store is running before we can join it. It
470470
%% could be stopped if RabbitMQ is not running for instance.
471471
ok = setup(),
472472
khepri:info(?RA_CLUSTER_NAME),
473473
_ = application:ensure_all_started(khepri_mnesia_migration),
474474
mnesia_to_khepri:sync_cluster_membership(?STORE_ID).
475475

476-
add_members([]) ->
477-
ok;
478-
add_members([UnclusteredNode | UnclusteredNodes]) ->
479-
ThisNode = node(),
480-
case check_cluster_consistency(UnclusteredNode, false) of
481-
{ok, _} ->
482-
case add_member(UnclusteredNode, ThisNode) of
483-
ok ->
484-
add_members(UnclusteredNodes);
485-
Error ->
486-
Error
487-
end;
488-
Error ->
489-
Error
490-
end.
491-
492476
%%%%%%%%
493477
%% TODO run_peer_discovery!!
494478
%%%%%%%

0 commit comments

Comments
 (0)