diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-09-20 13:32:22 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-09-20 13:32:22 +0100 |
| commit | a47462c0ba909d3d2ea729b0affbeae5c06b330d (patch) | |
| tree | 75c9d3b7e3ef38dbb9ce49902b5bfb8221323b90 | |
| parent | b9cc36b548530900d2b5c1cd53aa72e8a3b3d1ef (diff) | |
| download | rabbitmq-server-git-a47462c0ba909d3d2ea729b0affbeae5c06b330d.tar.gz | |
That case was originally written to cover the unmirrored case - but actually the queue might be mirrored but with no slaves, or about to become mirrored, or whatever. And our is_process_alive() check serves the same purpose.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 452b11b339..9d09742db8 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -297,8 +297,6 @@ lookup(Name) -> with(Name, F, E) -> case lookup(Name) of - {ok, Q = #amqqueue{slave_pids = []}} -> - rabbit_misc:with_exit_handler(E, fun () -> F(Q) end); {ok, Q = #amqqueue{pid = QPid}} -> %% We check is_process_alive(QPid) in case we receive a %% nodedown (for example) in F() that has nothing to do |