diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-02-13 01:52:01 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-02-13 01:52:01 +0300 |
| commit | 3550a172e34eae818aca449e40fa489cbe546336 (patch) | |
| tree | 54d7fc441c3cdb495abc3f14eb3aa8320d9f0567 | |
| parent | 0d0f39d8a3e3edc23d0aa9758fd4c15e01c7afda (diff) | |
| download | rabbitmq-server-git-3550a172e34eae818aca449e40fa489cbe546336.tar.gz | |
Naming
| -rw-r--r-- | src/rabbit_amqqueue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index f366eb43f5..ff3fef8f2b 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -128,11 +128,11 @@ recover_classic_queues(VHost, Queues) -> BQ:start(VHost, [amqqueue:get_name(Q) || Q <- Queues]), case rabbit_amqqueue_sup_sup:start_for_vhost(VHost) of {ok, _} -> - OkQueues = recover_durable_queues(lists:zip(Queues, OrderedRecoveryTerms)), - OkQueuesNames = [amqqueue:get_name(Q) || Q <- OkQueues], + RecoveredQs = recover_durable_queues(lists:zip(Queues, OrderedRecoveryTerms)), + RecoveredNames = [amqqueue:get_name(Q) || Q <- RecoveredQs], FailedQueues = [Q || Q <- Queues, - not lists:member(amqqueue:get_name(Q), OkQueuesNames)], - {OkQueues, FailedQueues}; + not lists:member(amqqueue:get_name(Q), RecoveredNames)], + {RecoveredQs, FailedQueues}; {error, Reason} -> rabbit_log:error("Failed to start queue supervisor for vhost '~s': ~s", [VHost, Reason]), throw({error, Reason}) |