diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-07-01 13:58:27 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-07-01 13:58:27 +0100 |
| commit | 16b9100350f8d1b7aec46a5450a98d8a303f7ce8 (patch) | |
| tree | 0c83b7d154f6c8e1a4eb98e48ce1ed67a2d3ab2b | |
| parent | 104c8c8931d9258dd0aba9cffb8f6f4387625b51 (diff) | |
| download | rabbitmq-server-git-16b9100350f8d1b7aec46a5450a98d8a303f7ce8.tar.gz | |
More consistent and correct nomenclature.
| -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) -> |