diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-01-22 16:35:45 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-22 16:35:45 +0100 |
| commit | e2048576006b487869203506c1a3599dd7eae608 (patch) | |
| tree | 9586ab11d74a075af96d174efcc5c28eaca77862 /src | |
| parent | d8f94900f087d7a381280bc46084ee859d4cd5ed (diff) | |
| parent | 9bd15aceb2ff34e8fde32a42a4b3daf935ba08fe (diff) | |
| download | rabbitmq-server-git-e2048576006b487869203506c1a3599dd7eae608.tar.gz | |
Merge pull request #2211 from rabbitmq/unsupported-if-flags-delete-qq
Unsupported if_empty and if_unused flags for delete quorum queues
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..3d0d074e02 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), |