DO NOT MERGE Remove CQv1

deps/rabbit/src/rabbit_amqqueue_process.erl

@@ -490,9 +490,7 @@ process_args_policy(State = #q{q                   = Q,
          {<<"message-ttl">>,             fun res_min/2, fun init_ttl/2},
          {<<"max-length">>,              fun res_min/2, fun init_max_length/2},
          {<<"max-length-bytes">>,        fun res_min/2, fun init_max_bytes/2},
-         {<<"overflow">>,                fun res_arg/2, fun init_overflow/2},
-         {<<"queue-mode">>,              fun res_arg/2, fun init_queue_mode/2},
-         {<<"queue-version">>,           fun res_arg/2, fun init_queue_version/2}],
+         {<<"overflow">>,                fun res_arg/2, fun init_overflow/2}],
       drop_expired_msgs(
          lists:foldl(fun({Name, Resolve, Fun}, StateN) ->
                              Fun(rabbit_queue_type_util:args_policy_lookup(Name, Resolve, Q), StateN)
@@ -543,22 +541,6 @@ init_overflow(Overflow, State) ->
             State#q{overflow = OverflowVal}
     end.
 
-init_queue_mode(undefined, State) ->
-    State;
-init_queue_mode(Mode, State = #q {backing_queue = BQ,
-                                  backing_queue_state = BQS}) ->
-    BQS1 = BQ:set_queue_mode(binary_to_existing_atom(Mode, utf8), BQS),
-    State#q{backing_queue_state = BQS1}.
-
-init_queue_version(Version0, State = #q {backing_queue = BQ,
-                                         backing_queue_state = BQS}) ->
-    Version = case Version0 of
-        undefined -> 2;
-        _ -> Version0
-    end,
-    BQS1 = BQ:set_queue_version(Version, BQS),
-    State#q{backing_queue_state = BQS1}.
-
 reply(Reply, NewState) ->
     {NewState1, Timeout} = next_state(NewState),
     {reply, Reply, ensure_stats_timer(ensure_rate_timer(NewState1)), Timeout}.

deps/rabbit/src/rabbit_backing_queue.erl

@@ -14,8 +14,7 @@
                     message_bytes, message_bytes_ready,
                     message_bytes_unacknowledged, message_bytes_ram,
                     message_bytes_persistent, head_message_timestamp,
-                    disk_reads, disk_writes, backing_queue_status,
-                    messages_paged_out, message_bytes_paged_out]).
+                    disk_reads, disk_writes, backing_queue_status]).
 
 %% We can't specify a per-queue ack/state with callback signatures
 -type ack()   :: any().
@@ -37,8 +36,8 @@
 -type msg_fun(A) :: fun ((mc:state(), ack(), A) -> A).
 -type msg_pred() :: fun ((rabbit_types:message_properties()) -> boolean()).
 
 -type queue_mode() :: atom().
 -type queue_version() :: pos_integer().
 
 %% Called on startup with a vhost and a list of durable queue names on this vhost.
 %% The queues aren't being started at this point, but this call allows the
@@ -173,13 +172,6 @@
 %% each message, its ack tag, and an accumulator.
 -callback ackfold(msg_fun(A), A, state(), [ack()]) -> {A, state()}.
 
-%% Fold over all the messages in a queue and return the accumulated
-%% results, leaving the queue undisturbed.
--callback fold(fun((mc:state(),
-                    rabbit_types:message_properties(),
-                    boolean(), A) -> {('stop' | 'cont'), A}),
-               A, state()) -> {A, state()}.
-
 %% How long is my queue?
 -callback len(state()) -> non_neg_integer().
 
@@ -223,10 +215,6 @@
 %% or discarded previously).
 -callback is_duplicate(mc:state(), state()) -> {boolean(), state()}.
 
--callback set_queue_mode(queue_mode(), state()) -> state().
-
--callback set_queue_version(queue_version(), state()) -> state().
-
 -callback zip_msgs_and_acks([delivered_publish()],
                             [ack()], Acc, state())
                            -> Acc.