diff options
| author | Gabriele Santomaggio <g.santomaggio@gmail.com> | 2021-10-12 19:09:34 +0200 |
|---|---|---|
| committer | Gabriele Santomaggio <g.santomaggio@gmail.com> | 2021-10-12 19:09:34 +0200 |
| commit | c270ebf03746ef8ea5df88e024a7a44ecf432614 (patch) | |
| tree | def4de4bcad32f3246e9c0a086cf402a1d68df7e | |
| parent | 4ce920cac551ae96bdb12a4d4d74087d7986de0c (diff) | |
| download | rabbitmq-server-git-c270ebf03746ef8ea5df88e024a7a44ecf432614.tar.gz | |
Disable the stream_plugin if the feature flag
is not enabled.
fixes https://github.com/rabbitmq/rabbitmq-server/issues/3557
| -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, |