HTTP API: DELETE /api/queues/{vhost}/{name} use internal API call

A direct client operation fails if the queue is exclusive. This
API should behave like the rabbitmqctl that can delete the queue
even in that case

Author: dcorbacho

deps/rabbit/src/rabbit_amqqueue.erl

@@ -1603,7 +1603,12 @@ delete_immediately_by_resource(Resources) ->
             rabbit_types:error('not_empty') |
             {protocol_error, Type :: atom(), Reason :: string(), Args :: term()}.
 delete(Q, IfUnused, IfEmpty, ActingUser) ->
-    rabbit_queue_type:delete(Q, IfUnused, IfEmpty, ActingUser).
+    rabbit_log:warning("TRACE delete queue ~p~n before ~p~n",
+                       [amqqueue:get_name(Q), list()]),
+    Ret = rabbit_queue_type:delete(Q, IfUnused, IfEmpty, ActingUser),
+    rabbit_log:warning("TRACE delete queue ~p~n after ~p~n",
+                       [amqqueue:get_name(Q), list()]),
+    Ret.
 
 -spec delete_with(amqqueue:amqqueue() | name(), boolean(), boolean(), rabbit_types:username()) ->
     rabbit_types:ok(integer()) | rabbit_misc:channel_or_connection_exit().

deps/rabbitmq_management/src/rabbit_mgmt_wm_queue.erl

@@ -71,18 +71,31 @@ accept_content(ReqData, Context) ->
             rabbit_mgmt_util:bad_request(iolist_to_binary(io_lib:format(F ++ "~n", A)), ReqData, Context)
     end.
 
-delete_resource(ReqData, Context) ->
+delete_resource(ReqData, Context = #context{user = #user{username = ActingUser}}) ->
     %% We need to retrieve manually if-unused and if-empty, as the HTTP API uses '-'
     %% while the record uses '_'
     IfUnused = <<"true">> =:= rabbit_mgmt_util:qs_val(<<"if-unused">>, ReqData),
     IfEmpty = <<"true">> =:= rabbit_mgmt_util:qs_val(<<"if-empty">>, ReqData),
-    Name = rabbit_mgmt_util:id(queue, ReqData),
-    rabbit_mgmt_util:direct_request(
-      'queue.delete',
-      fun rabbit_mgmt_format:format_accept_content/1,
-      [{queue, Name},
-       {if_unused, IfUnused},
-       {if_empty, IfEmpty}], "Delete queue error: ~ts", ReqData, Context).
+    VHost = rabbit_mgmt_util:id(vhost, ReqData),
+    QName = rabbit_mgmt_util:id(queue, ReqData),
+    Name = rabbit_misc:r(VHost, queue, QName),
+    case rabbit_amqqueue:lookup(Name) of
+        {ok, Q} ->
+            case rabbit_amqqueue:delete(Q, IfUnused, IfEmpty, ActingUser) of
+                {ok, _} ->
+                    {true, ReqData, Context};
+                {error, not_empty} ->
+                    Explanation = io_lib:format("~ts not empty", [rabbit_misc:rs(Name)]),
+                    rabbit_log:warning("Delete queue error: ~ts", [Explanation]),
+                    rabbit_mgmt_util:bad_request(list_to_binary(Explanation), ReqData, Context);
+                {error, in_use} ->
+                    Explanation = io_lib:format("~ts in use", [rabbit_misc:rs(Name)]),
+                    rabbit_log:warning("Delete queue error: ~ts", [Explanation]),
+                    rabbit_mgmt_util:bad_request(list_to_binary(Explanation), ReqData, Context)
+            end;
+        {error, not_found} ->
+            {true, ReqData, Context}
+   end.
 
 is_authorized(ReqData, Context) ->
     rabbit_mgmt_util:is_authorized_vhost(ReqData, Context).

deps/rabbitmq_management/test/rabbit_mgmt_http_SUITE.erl

@@ -1993,9 +1993,7 @@ queue_purge_test(Config) ->
     http_delete(Config, "/queues/%2F/myqueue/contents", {group, '2xx'}),
     http_delete(Config, "/queues/%2F/badqueue/contents", ?NOT_FOUND),
     http_delete(Config, "/queues/%2F/exclusive/contents", ?BAD_REQUEST),
-    http_delete(Config, "/queues/%2F/exclusive", ?BAD_REQUEST),
-    #'basic.get_empty'{} =
-        amqp_channel:call(Ch, #'basic.get'{queue = <<"myqueue">>}),
+    http_delete(Config, "/queues/%2F/exclusive", {group, '2xx'}),
     close_channel(Ch),
     close_connection(Conn),
     http_delete(Config, "/queues/%2F/myqueue", {group, '2xx'}),