Merge pull request #13360 from rabbitmq/remove-set-stream-retention-policy-command

Remove set_stream_retention_policy command

Author: acogoluegnes

deps/rabbit/docs/rabbitmq-streams.8

@@ -5,7 +5,7 @@
 .\"
 .\" Copyright (c) 2007-2025 Broadcom. All Rights Reserved. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries.  All rights reserved.
 .\"
-.Dd June 22, 2023
+.Dd February 18, 2025
 .Dt RABBITMQ-STREAMS 8
 .Os "RabbitMQ Server"
 .Sh NAME
@@ -129,18 +129,6 @@ Example:
 .Dl rabbitmq-streams restart_stream --vhost Qo a-vhost Qc Qo a-stream Qc --preferred-leader-node Qo node
 .\" ------------------------------------
 .El
-.Ss Policies
-.Bl -tag -width Ds
-.\" ------------------------------------
-.It Cm set_stream_retention_policy Ar stream Ar policy Fl -vhost Ar virtual-host
-.Pp
-Set the retention policy of a stream.
-.Pp
-Example:
-.Sp
-.Dl rabbitmq-streams set_stream_retention_policy --vhost Qo a-vhost Qc Qo a-stream Qc Qo a-policy Qc
-.\" ------------------------------------
-.El
 .Ss Stream plugin
 .Bl -tag -width Ds
 .\" ------------------------------------------------------------------

deps/rabbit/src/rabbit_stream_queue.erl

@@ -42,7 +42,6 @@
 
 -export([list_with_minimum_quorum/0]).
 
--export([set_retention_policy/3]).
 -export([restart_stream/3,
          add_replica/3,
          delete_replica/3,
@@ -1002,24 +1001,6 @@ update_leader_pid(Pid, #stream_client{} =  State) ->
 state_info(_) ->
     #{}.
 
-set_retention_policy(Name, VHost, Policy) ->
-    case rabbit_amqqueue:check_max_age(Policy) of
-        {error, _} = E ->
-            E;
-        MaxAge ->
-            QName = queue_resource(VHost, Name),
-            Fun = fun(Q) ->
-                          Conf = amqqueue:get_type_state(Q),
-                          amqqueue:set_type_state(Q, Conf#{max_age => MaxAge})
-                  end,
-            case rabbit_amqqueue:update(QName, Fun) of
-                not_found ->
-                    {error, not_found};
-                _ ->
-                    ok
-            end
-    end.
-
 -spec restart_stream(VHost :: binary(), Queue :: binary(),
                      #{preferred_leader_node => node()}) ->
     {ok, node()} |