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 | 1a58ae7a4a572cac2a8ac7b1083b8117df033c2e (patch) | |
| tree | 8b571bdd90e504557eafedd882cf4ca8f011cff1 /src | |
| parent | 1cd553e672b72b0fdf641b73f6bc95a30efac6ec (diff) | |
| download | rabbitmq-server-git-1a58ae7a4a572cac2a8ac7b1083b8117df033c2e.tar.gz | |
A rather crucial infinity missing
(transplanted from aaf79aa3cacefee1742eb7f257c6a16ec5720d59)
Diffstat (limited to 'src')
| -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 2453280e34..0cdb4fff08 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), |