diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-10-20 14:53:08 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-10-20 14:53:08 +0200 |
| commit | 6aabfdbbb45b67c0da674736235d3e4714d39fb0 (patch) | |
| tree | 91d08e2f969a6f6c5181803c350a5f66f738789d | |
| parent | 9cf18e83f279408e20430b55428a2b19156c90d7 (diff) | |
| download | rabbitmq-server-git-6aabfdbbb45b67c0da674736235d3e4714d39fb0.tar.gz | |
Format stream plugin
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream.erl | 22 |
1 files changed, 12 insertions, 10 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream.erl b/deps/rabbitmq_stream/src/rabbit_stream.erl index 6d27dcbc7d..a8c9c824aa 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream.erl @@ -43,20 +43,22 @@ start(_Type, _Args) -> 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_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()} + 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. - - tls_host() -> case application:get_env(rabbitmq_stream, advertised_tls_host, undefined) |