diff options
author | Michael Klishin <michael@clojurewerkz.org> | 2021-10-14 17:20:59 +0300 |
---|---|---|
committer | Michael Klishin <michael@clojurewerkz.org> | 2021-10-14 17:20:59 +0300 |
commit | 2fbc5fab252a26c3d7b816f44d536ce4d41cf35b (patch) | |
tree | ff1d15f9f488c58088cf8467125b522081c03ca7 | |
parent | f2df98aef99a0b721e9e9c15dda3326f1c8fb2d9 (diff) | |
download | rabbitmq-server-git-2fbc5fab252a26c3d7b816f44d536ce4d41cf35b.tar.gz |
Formatting, wording
-rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream.erl | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream.erl b/deps/rabbitmq_stream/src/rabbit_stream.erl index 058f85e164..6d27dcbc7d 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream.erl @@ -41,18 +41,18 @@ start(_Type, _Args) -> 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 stream_queue feature flag is disabled. "++ - "You need to enable stream_queue feature flag then disable and re-enable the rabbitmq_stream plugin. ", - "See https://www.rabbitmq.com/feature-flags.html ", - []), - {ok, self()} + 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 stream_queue feature flag is disabled. "++ + "Enable stream_queue feature flag then disable and re-enable the rabbitmq_stream plugin. ", + "See https://www.rabbitmq.com/feature-flags.html to learn more", + []), + {ok, self()} end. |