diff options
author | Gabriele Santomaggio <g.santomaggio@gmail.com> | 2021-10-12 19:09:34 +0200 |
---|---|---|
committer | mergify-bot <noreply@mergify.io> | 2021-10-14 15:46:21 +0000 |
commit | 35084e7366f7f72517d9fde46f99d7ce93900567 (patch) | |
tree | 5a275bd440a7b0ed66895f23e3377b8ba3aec851 | |
parent | 9fccd84927522d60634b342a08699cde2f2a0906 (diff) | |
download | rabbitmq-server-git-35084e7366f7f72517d9fde46f99d7ce93900567.tar.gz |
Disable the stream_plugin if the feature flag
is not enabled.
fixes https://github.com/rabbitmq/rabbitmq-server/issues/3557
(cherry picked from commit c270ebf03746ef8ea5df88e024a7a44ecf432614)
-rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream.erl | 22 |
1 files changed, 17 insertions, 5 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream.erl b/deps/rabbitmq_stream/src/rabbit_stream.erl index b2da103c6e..1ccbdf6225 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream.erl @@ -39,11 +39,23 @@ -include("rabbit_stream_metrics.hrl"). start(_Type, _Args) -> - rabbit_stream_metrics:init(), - rabbit_global_counters:init([{protocol, stream}], ?PROTOCOL_COUNTERS), - rabbit_global_counters:init([{protocol, stream}, - {queue_type, ?STREAM_QUEUE_TYPE}]), - rabbit_stream_sup:start_link(). + FeatureFlagsEnabled = rabbit_ff_registry:list(enabled), + case maps:is_key(stream_queue, FeatureFlagsEnabled) of + true -> rabbit_stream_metrics:init(), + rabbit_global_counters:init([{protocol, stream}], ?PROTOCOL_COUNTERS), + rabbit_global_counters:init([{protocol, stream}, + {queue_type, ?STREAM_QUEUE_TYPE}]), + 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", + []), + + {ok, self()} + end. + + tls_host() -> case application:get_env(rabbitmq_stream, advertised_tls_host, |