diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2020-02-07 17:17:47 +0000 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-02-08 19:24:54 +0300 |
| commit | ea24a686d8525c01543e03487a067e8161aa6011 (patch) | |
| tree | 6cb4aa3a48143fa2c8888b3c03c8a77b78b0f730 | |
| parent | 0e5f6824004543b63102fe7c211b4364f5c3adbc (diff) | |
| download | rabbitmq-server-git-ea24a686d8525c01543e03487a067e8161aa6011.tar.gz | |
improve handling of absent queues assumed to be alive
| -rw-r--r-- | src/rabbit_amqqueue.erl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index ce048726ac..ac91689df3 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -765,7 +765,13 @@ priv_absent(QueueName, _QPid, _IsDurable, crashed) -> priv_absent(QueueName, _QPid, _IsDurable, timeout) -> rabbit_misc:protocol_error( not_found, - "failed to perform operation on ~s due to timeout", [rabbit_misc:rs(QueueName)]). + "failed to perform operation on ~s due to timeout", [rabbit_misc:rs(QueueName)]); + +priv_absent(QueueName, QPid, _IsDurable, alive) -> + rabbit_misc:protocol_error( + not_found, + "failed to perform operation on ~s due to its inconsistent pid ~s", + [rabbit_misc:rs(QueueName), QPid]). -spec assert_equivalence (amqqueue:amqqueue(), boolean(), boolean(), |