diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2020-01-15 16:42:39 +0100 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2020-01-15 16:44:24 +0100 |
| commit | 6703f77b5e6d0237f5cdd8feb01bd26b8c63b856 (patch) | |
| tree | 411bea1889f5d7c16c476f2798a2e0ed53eee866 /src | |
| parent | 04700dde4a79ab6501b282d21b9bc3c876e732db (diff) | |
| download | rabbitmq-server-git-6703f77b5e6d0237f5cdd8feb01bd26b8c63b856.tar.gz | |
Unsupported if_empty and if_unused flags for delete quorum queues
[#167065717]
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index b8df6a3028..0c4a8b07c0 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -444,6 +444,16 @@ stop(VHost) -> rabbit_types:username()) -> {ok, QLen :: non_neg_integer()}. +delete(Q, true, _IfEmpty, ActingUser) when ?amqqueue_is_quorum(Q) -> + rabbit_misc:protocol_error( + not_implemented, + "cannot delete ~s. queue.delete operations with if-unused flag set are not supported by quorum queues", + [rabbit_misc:rs(amqqueue:get_name(Q))]); +delete(Q, _IfUnused, true, ActingUser) when ?amqqueue_is_quorum(Q) -> + rabbit_misc:protocol_error( + not_implemented, + "cannot delete ~s. queue.delete operations with if-empty flag set are not supported by quorum queues", + [rabbit_misc:rs(amqqueue:get_name(Q))]); delete(Q, _IfUnused, _IfEmpty, ActingUser) when ?amqqueue_is_quorum(Q) -> {Name, _} = amqqueue:get_pid(Q), |