diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-08-18 17:29:35 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-08-18 17:29:35 +0100 |
| commit | 829a56efa6820cc46cf4f3f12a9e22a21c4befe5 (patch) | |
| tree | 8b571bdd90e504557eafedd882cf4ca8f011cff1 | |
| parent | 1be42abfe0c3ce186591a4daffa8e51d5fce19d7 (diff) | |
| download | rabbitmq-server-829a56efa6820cc46cf4f3f12a9e22a21c4befe5.tar.gz | |
A rather crucial infinity missing
(transplanted from aaf79aa3cacefee1742eb7f257c6a16ec5720d59)
| -rw-r--r-- | src/rabbit_amqqueue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 2453280e..0cdb4fff 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -197,7 +197,8 @@ find_durable_queues() -> recover_durable_queues(DurableQueues) -> Qs = [start_queue_process(Q) || Q <- DurableQueues], - [Q || Q <- Qs, gen_server2:call(Q#amqqueue.pid, {init, true}) == Q]. + [Q || Q <- Qs, + gen_server2:call(Q#amqqueue.pid, {init, true}, infinity) == Q]. declare(QueueName, Durable, AutoDelete, Args, Owner) -> ok = check_declare_arguments(QueueName, Args), |