diff --git a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl index 598da4a768..d5500de2a4 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl @@ -47,10 +47,13 @@ create(VirtualHost, Reference, Arguments, Username) -> StreamQueueArguments = stream_queue_arguments(Arguments), maybe ok ?= validate_stream_queue_arguments(StreamQueueArguments), + true ?= rabbit_stream_queue:is_enabled(), do_create_stream(VirtualHost, Reference, StreamQueueArguments, Username) else error -> {error, validation_failed}; + false -> + {error, validation_failed}; {error, _} = Err -> Err end.