Remove rabbit_queue_collector

rabbit_queue_collector is responsible for synchronously deleting
exclusive queues. Since the AMQP 1.0 plugin never creates exclusive
queues, rabbit_queue_collector doesn't need to be started in the first
place. This will save 1 Erlang process per AMQP 1.0 connection.

Author: ansd

deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_reader.erl

@@ -29,7 +29,7 @@
 %%--------------------------------------------------------------------------
 
 -record(v1, {parent, sock, connection, callback, recv_len, pending_recv,
-             connection_state, queue_collector, heartbeater, helper_sup,
+             connection_state, heartbeater, helper_sup,
              channel_sup_sup_pid, buf, buf_len, throttle, proxy_socket,
              tracked_channels}).
 
@@ -61,7 +61,6 @@ unpack_from_0_9_1(
         recv_len            = RecvLen,
         pending_recv        = PendingRecv,
         connection_state    = pre_init,
-        queue_collector     = undefined,
         heartbeater         = none,
         helper_sup          = HelperSupPid,
         buf                 = Buf,
@@ -411,10 +410,6 @@ handle_1_0_connection_frame(#'v1_0.open'{ max_frame_size = ClientFrameMax,
                                "frame_max=~w < ~w min size",
                                [FrameMax, ?FRAME_1_0_MIN_SIZE]);
            true ->
-                {ok, Collector} =
-                    %% TODO Do we still need the queue_collector?
-                    rabbit_connection_helper_sup:start_queue_collector(
-                      HelperSupPid, <<"AMQP 1.0">>), %% TODO describe the connection
                 SendFun =
                     fun() ->
                             Frame =
@@ -439,8 +434,7 @@ handle_1_0_connection_frame(#'v1_0.open'{ max_frame_size = ClientFrameMax,
                          connection = Connection#v1_connection{
                                                    frame_max = FrameMax,
                                                    hostname  = Hostname},
-                         heartbeater = Heartbeater,
-                         queue_collector = Collector}
+                         heartbeater = Heartbeater}
         end,
     HostnameVal = case Hostname of
                     undefined -> undefined;