diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-10-14 17:20:59 +0300 |
|---|---|---|
| committer | mergify-bot <noreply@mergify.io> | 2021-10-14 15:46:23 +0000 |
| commit | 522bf3145670a24f907b055486d71c9340fe79da (patch) | |
| tree | 520f607c0607f5989e795cc66d3f92a8d2152709 | |
| parent | c2fc5bf65591e8d967d35240b5fea11db86a04bc (diff) | |
| download | rabbitmq-server-git-522bf3145670a24f907b055486d71c9340fe79da.tar.gz | |
Formatting, wording
(cherry picked from commit 2fbc5fab252a26c3d7b816f44d536ce4d41cf35b)
| -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. |