diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_tests.erl | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index a186fb7a68..bd11e8bfcc 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -1666,16 +1666,12 @@ test_declare_on_dead_queue(SecondaryNode) -> rabbit_amqqueue:declare(QueueName, false, false, [], none), exit(QPid, kill), - Self ! {self(), killed, QPid} + Self ! {self(), killed} end), receive - {Pid, killed, QPid} -> - {existing, #amqqueue{name = QueueName, - pid = QPid}} = - rabbit_amqqueue:declare(QueueName, false, false, [], none), - false = rabbit_misc:is_process_alive(QPid), - {new, Q} = rabbit_amqqueue:declare(QueueName, false, false, [], - none), + {Pid, killed} -> + {existing, Q} = rabbit_amqqueue:declare(QueueName, false, false, [], + none), true = rabbit_misc:is_process_alive(Q#amqqueue.pid), {ok, 0} = rabbit_amqqueue:delete(Q, false, false), passed |