diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-02-13 02:07:28 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-02-13 02:07:28 +0300 |
| commit | 76c7a01fe4871d1d64057214b68f8246d265322c (patch) | |
| tree | 2a39bcc10ccdef81997be2f5342f73e7d432797b | |
| parent | 2e92a20569c78faffaf86107bf0ef8ddf70d5ce6 (diff) | |
| download | rabbitmq-server-git-76c7a01fe4871d1d64057214b68f8246d265322c.tar.gz | |
Naming
| -rw-r--r-- | src/rabbit_amqqueue.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index ff3fef8f2b..8ddb649bc8 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -109,15 +109,15 @@ warn_file_limit() -> end. -spec recover(rabbit_types:vhost()) -> - {ClassicOk :: [amqqueue:amqqueue()], - ClassicFailed :: [amqqueue:amqqueue()], + {RecoveredClassic :: [amqqueue:amqqueue()], + FailedClassic :: [amqqueue:amqqueue()], Quorum :: [amqqueue:amqqueue()]}. recover(VHost) -> - Classic = find_local_durable_classic_queues(VHost), + AllClassic = find_local_durable_classic_queues(VHost), Quorum = find_local_quorum_queues(VHost), - {ClassicOk, ClassicFailed} = recover_classic_queues(VHost, Classic), - {ClassicOk, ClassicFailed, rabbit_quorum_queue:recover(Quorum)}. + {RecoveredClassic, FailedClassic} = recover_classic_queues(VHost, AllClassic), + {RecoveredClassic, FailedClassic, rabbit_quorum_queue:recover(Quorum)}. recover_classic_queues(VHost, Queues) -> {ok, BQ} = application:get_env(rabbit, backing_queue_module), |