diff --git a/deps/rabbit/src/rabbit_ff_controller.erl b/deps/rabbit/src/rabbit_ff_controller.erl index ce826676801..b1f919d489e 100644 --- a/deps/rabbit/src/rabbit_ff_controller.erl +++ b/deps/rabbit/src/rabbit_ff_controller.erl @@ -306,6 +306,14 @@ terminate(_Reason, _State, _Data) -> ok. wait_for_in_flight_operations() -> + case global:whereis_name(?GLOBAL_NAME) of + Pid when Pid == self() -> + ok; + _ -> + wait_for_in_flight_operations0() + end. + +wait_for_in_flight_operations0() -> case register_globally() of yes -> %% We don't unregister so the controller holds the lock until it