Skip to content

Commit 3550a17

Browse files
Naming
1 parent 0d0f39d commit 3550a17

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/rabbit_amqqueue.erl

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -128,11 +128,11 @@ recover_classic_queues(VHost, Queues) ->
128128
BQ:start(VHost, [amqqueue:get_name(Q) || Q <- Queues]),
129129
case rabbit_amqqueue_sup_sup:start_for_vhost(VHost) of
130130
{ok, _} ->
131-
OkQueues = recover_durable_queues(lists:zip(Queues, OrderedRecoveryTerms)),
132-
OkQueuesNames = [amqqueue:get_name(Q) || Q <- OkQueues],
131+
RecoveredQs = recover_durable_queues(lists:zip(Queues, OrderedRecoveryTerms)),
132+
RecoveredNames = [amqqueue:get_name(Q) || Q <- RecoveredQs],
133133
FailedQueues = [Q || Q <- Queues,
134-
not lists:member(amqqueue:get_name(Q), OkQueuesNames)],
135-
{OkQueues, FailedQueues};
134+
not lists:member(amqqueue:get_name(Q), RecoveredNames)],
135+
{RecoveredQs, FailedQueues};
136136
{error, Reason} ->
137137
rabbit_log:error("Failed to start queue supervisor for vhost '~s': ~s", [VHost, Reason]),
138138
throw({error, Reason})

0 commit comments

Comments
 (0)