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 | 352e716468d82e536ce5e50d8bc34487509f5763 (patch) | |
| tree | 75c9d3b7e3ef38dbb9ce49902b5bfb8221323b90 | |
| parent | 2965eaf2eba0db8dc59dd7a73a33f278fc1723e6 (diff) | |
| download | rabbitmq-server-352e716468d82e536ce5e50d8bc34487509f5763.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 452b11b3..9d09742d 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 |