Disable the stream_plugin and stream management if the feature flag

is not enabled.
fixes #3557

Author: Gsantomaggio

deps/rabbitmq_stream/src/rabbit_stream.erl

@@ -48,10 +48,10 @@ start(_Type, _Args) ->
       rabbit_stream_sup:start_link();
     false ->
        rabbit_log:warning(
-         "Unable to start the stream plugin. The feature flag stream_queue is disabled \n"++
-         "You need to enable it and restart the broker",
+         "Unable to start the stream plugin. The stream_queue feature flag is disabled. "++
+         "You need to enable it then disable and re-enable the rabbitmq_stream plugin. ",
+         "See https://www.rabbitmq.com/feature-flags.html ",
         []),
-
       {ok, self()}
     end.
 

deps/rabbitmq_stream_management/src/rabbit_stream_connection_consumers_mgmt.erl

@@ -22,7 +22,11 @@
 -include_lib("rabbit_common/include/rabbit.hrl").
 
 dispatcher() ->
-    [{"/stream/connections/:vhost/:connection/consumers", ?MODULE, []}].
+    case rabbit_stream_management_utils:is_feature_flag_enabled() of
+      true ->   [{"/stream/connections/:vhost/:connection/consumers", ?MODULE, []}];
+      false -> []
+    end.
+
 
 web_ui() ->
     [].

deps/rabbitmq_stream_management/src/rabbit_stream_connection_mgmt.erl

@@ -24,7 +24,11 @@
 -include_lib("rabbit_common/include/rabbit.hrl").
 
 dispatcher() ->
-    [{"/stream/connections/:vhost/:connection", ?MODULE, []}].
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true -> [{"/stream/connections/:vhost/:connection", ?MODULE, []}];
+    false -> []
+  end.
+
 
 web_ui() ->
     [].

deps/rabbitmq_stream_management/src/rabbit_stream_connection_publishers_mgmt.erl

@@ -22,7 +22,11 @@
 -include_lib("rabbit_common/include/rabbit.hrl").
 
 dispatcher() ->
-    [{"/stream/connections/:vhost/:connection/publishers", ?MODULE, []}].
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true ->    [{"/stream/connections/:vhost/:connection/publishers", ?MODULE, []}];
+    false -> []
+  end.
+
 
 web_ui() ->
     [].

deps/rabbitmq_stream_management/src/rabbit_stream_connections_mgmt.erl

@@ -19,10 +19,22 @@
 -include_lib("rabbitmq_management_agent/include/rabbit_mgmt_records.hrl").
 
 dispatcher() ->
-    [{"/stream/connections", ?MODULE, []}].
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true ->  [{"/stream/connections", ?MODULE, []}];
+    false -> []
+  end.
+
 
 web_ui() ->
-    [{javascript, <<"stream.js">>}].
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true -> [{javascript, <<"stream.js">>}];
+    false ->  rabbit_log:warning(
+      "Unable to show the stream management plugin. The stream_queue feature flag is disabled. "++
+      "You need to enable it then disable and re-enable the rabbitmq_stream_management plugin. ",
+      "See https://www.rabbitmq.com/feature-flags.html ",
+      []),
+      []
+  end.
 
 %%--------------------------------------------------------------------
 

deps/rabbitmq_stream_management/src/rabbit_stream_connections_vhost_mgmt.erl

@@ -21,7 +21,10 @@
 -include_lib("amqp_client/include/amqp_client.hrl").
 
 dispatcher() ->
-    [{"/stream/connections/:vhost", ?MODULE, []}].
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true -> [{"/stream/connections/:vhost", ?MODULE, []}];
+    false -> []
+  end.
 
 web_ui() ->
     [].

deps/rabbitmq_stream_management/src/rabbit_stream_consumers_mgmt.erl

@@ -21,8 +21,11 @@
 -include_lib("rabbit_common/include/rabbit.hrl").
 
 dispatcher() ->
-    [{"/stream/consumers", ?MODULE, []},
-     {"/stream/consumers/:vhost", ?MODULE, []}].
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true -> [{"/stream/consumers", ?MODULE, []},
+     {"/stream/consumers/:vhost", ?MODULE, []}];
+    false -> []
+  end.
 
 web_ui() ->
     [].

deps/rabbitmq_stream_management/src/rabbit_stream_management_utils.erl

@@ -9,7 +9,8 @@
 
 -export([keep_stream_connections/1,
          keep_tracked_stream_connections/1,
-         is_stream_connection/1]).
+         is_stream_connection/1,
+         is_feature_flag_enabled/0]).
 
 -include_lib("rabbit_common/include/rabbit.hrl").
 
@@ -31,3 +32,7 @@ keep_tracked_stream_connections(Connections) ->
                          false
                  end,
                  Connections).
+
+is_feature_flag_enabled() ->
+  FeatureFlagsEnabled = rabbit_ff_registry:list(enabled),
+  maps:is_key(stream_queue, FeatureFlagsEnabled).

deps/rabbitmq_stream_management/src/rabbit_stream_publishers_mgmt.erl

@@ -21,9 +21,12 @@
 -include_lib("rabbit_common/include/rabbit.hrl").
 
 dispatcher() ->
-    [{"/stream/publishers", ?MODULE, []},
+  case rabbit_stream_management_utils:is_feature_flag_enabled() of
+    true -> [{"/stream/publishers", ?MODULE, []},
      {"/stream/publishers/:vhost", ?MODULE, []},
-     {"/stream/publishers/:vhost/:queue", ?MODULE, []}].
+     {"/stream/publishers/:vhost/:queue", ?MODULE, []}];
+    false -> []
+  end.
 
 web_ui() ->
     [].