remove non-rpc'd call to is_process_alive - now matches the rpc version in amqqueue_process

1 files changed, 5 insertions, 4 deletions

diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index a6da551d..053b6c6f 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -218,10 +218,11 @@ internal_declare(Q = #amqqueue{name = QueueName}, false) ->
                                  rabbit_misc:const(not_found)
                       end;
                   [ExistingQ = #amqqueue{pid = QPid}] ->
-                      case is_process_alive(QPid) of
-                          true  -> rabbit_misc:const(ExistingQ);
-                          false -> TailFun = internal_delete(QueueName),
-                                   fun (Tx) -> TailFun(Tx), ExistingQ end
+                      case rpc:call(
+                             node(QPid), erlang, is_process_alive, [QPid]) of
+                          true -> rabbit_misc:const(ExistingQ);
+                          _    -> TailFun = internal_delete(QueueName),
+                                  fun (Tx) -> TailFun(Tx), ExistingQ end
                       end
               end
       end).