diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index dc2a7a3f17..a0c065980a 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -276,7 +276,7 @@ terminate_shutdown(Fun, State = #q{q = Q}) -> undefined -> State1; _ -> ok = rabbit_memory_monitor:deregister(self()), QName = qname(State), - rabbit_federation_queue:terminate(Q), + rabbit_federation_queue:maybe_stop(Q), [emit_consumer_deleted(Ch, CTag, QName) || {Ch, CTag, _} <- consumers(State1)], State1#q{backing_queue_state = Fun(BQS)} @@ -547,7 +547,7 @@ notify_federation(#q{q = Q, IsEmpty = BQ:is_empty(BQS), case IsEmpty andalso active_unfederated(ActiveConsumers) of true -> rabbit_federation_queue:run(Q); - false -> rabbit_federation_queue:stop(Q) + false -> rabbit_federation_queue:pause(Q) end. active_unfederated(Cs) -> |