|
41 | 41 | start(_Type, _Args) ->
|
42 | 42 | FeatureFlagsEnabled = rabbit_ff_registry:list(enabled),
|
43 | 43 | case maps:is_key(stream_queue, FeatureFlagsEnabled) of
|
44 |
| - true -> rabbit_stream_metrics:init(), |
45 |
| - rabbit_global_counters:init([{protocol, stream}], ?PROTOCOL_COUNTERS), |
46 |
| - rabbit_global_counters:init([{protocol, stream}, |
47 |
| - {queue_type, ?STREAM_QUEUE_TYPE}]), |
48 |
| - rabbit_stream_sup:start_link(); |
49 |
| - false -> |
50 |
| - rabbit_log:warning( |
51 |
| - "Unable to start the stream plugin. The stream_queue feature flag is disabled. "++ |
52 |
| - "You need to enable stream_queue feature flag then disable and re-enable the rabbitmq_stream plugin. ", |
53 |
| - "See https://www.rabbitmq.com/feature-flags.html ", |
54 |
| - []), |
55 |
| - {ok, self()} |
| 44 | + true -> |
| 45 | + rabbit_stream_metrics:init(), |
| 46 | + rabbit_global_counters:init([{protocol, stream}], ?PROTOCOL_COUNTERS), |
| 47 | + rabbit_global_counters:init([{protocol, stream}, {queue_type, ?STREAM_QUEUE_TYPE}]), |
| 48 | + rabbit_stream_sup:start_link(); |
| 49 | + false -> |
| 50 | + rabbit_log:warning( |
| 51 | + "Unable to start the stream plugin. The stream_queue feature flag is disabled. "++ |
| 52 | + "Enable stream_queue feature flag then disable and re-enable the rabbitmq_stream plugin. ", |
| 53 | + "See https://www.rabbitmq.com/feature-flags.html to learn more", |
| 54 | + []), |
| 55 | + {ok, self()} |
56 | 56 | end.
|
57 | 57 |
|
58 | 58 |
|
|
0 commit comments