We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2e92a20 commit 76c7a01Copy full SHA for 76c7a01
src/rabbit_amqqueue.erl
@@ -109,15 +109,15 @@ warn_file_limit() ->
109
end.
110
111
-spec recover(rabbit_types:vhost()) ->
112
- {ClassicOk :: [amqqueue:amqqueue()],
113
- ClassicFailed :: [amqqueue:amqqueue()],
+ {RecoveredClassic :: [amqqueue:amqqueue()],
+ FailedClassic :: [amqqueue:amqqueue()],
114
Quorum :: [amqqueue:amqqueue()]}.
115
116
recover(VHost) ->
117
- Classic = find_local_durable_classic_queues(VHost),
+ AllClassic = find_local_durable_classic_queues(VHost),
118
Quorum = find_local_quorum_queues(VHost),
119
- {ClassicOk, ClassicFailed} = recover_classic_queues(VHost, Classic),
120
- {ClassicOk, ClassicFailed, rabbit_quorum_queue:recover(Quorum)}.
+ {RecoveredClassic, FailedClassic} = recover_classic_queues(VHost, AllClassic),
+ {RecoveredClassic, FailedClassic, rabbit_quorum_queue:recover(Quorum)}.
121
122
recover_classic_queues(VHost, Queues) ->
123
{ok, BQ} = application:get_env(rabbit, backing_queue_module),
0 commit comments