diff options
| -rw-r--r-- | src/rabbit.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index de2fec574c..c84d6de4cb 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -138,8 +138,8 @@ {mfa, {rabbit_exchange, recover, []}}, {requires, empty_db_check}]}). --rabbit_boot_step({message_store_queue_sup_queue_recovery, - [{description, "message store, queue supervisor and queue recovery"}, +-rabbit_boot_step({queue_sup_queue_recovery, + [{description, "queue supervisor and queue recovery"}, {mfa, {rabbit_amqqueue, start, []}}, {requires, empty_db_check}, {enables, routing_ready}]}). diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 87f12df19a..6fe60bba99 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -162,9 +162,9 @@ recover_durable_queues(DurableQueues) -> [] -> false end end) of - true -> [Q|Acc]; - false -> exit(Q#amqqueue.pid, shutdown), - Acc + true -> [Q | Acc]; + false -> exit(Q#amqqueue.pid, shutdown), + Acc end end, [], DurableQueues), %% Issue inits to *all* the queues so that they all init at the same time |