File tree Expand file tree Collapse file tree 1 file changed +11
-3
lines changed Expand file tree Collapse file tree 1 file changed +11
-3
lines changed Original file line number Diff line number Diff line change @@ -951,7 +951,7 @@ are_cmqs_permitted() ->
951
951
are_cmqs_used (_ ) ->
952
952
case rabbit_khepri :get_feature_state () of
953
953
enabled ->
954
- are_cmqs_used1 () ;
954
+ false ;
955
955
_ ->
956
956
% % If we are using Mnesia, we want to check manually if the table
957
957
% % exists first. Otherwise it can conflict with the way
@@ -962,8 +962,16 @@ are_cmqs_used(_) ->
962
962
RuntimeParamsReady = lists :member (
963
963
rabbit_runtime_parameters , AllTables ),
964
964
case RuntimeParamsReady of
965
- true -> are_cmqs_used1 ();
966
- false -> false
965
+ true ->
966
+ % % We also wait for the table because it could exist but
967
+ % % may be unavailable. For instance, Mnesia needs another
968
+ % % replica on another node before it considers it to be
969
+ % % available.
970
+ rabbit_table :wait (
971
+ [rabbit_runtime_parameters ], _Retry = true ),
972
+ are_cmqs_used1 ();
973
+ false ->
974
+ false
967
975
end
968
976
end .
969
977
You can’t perform that action at this time.
0 commit comments