Skip to content

Commit 1c264fa

Browse files
rabbitmq_streams: Check rabbit_queue_types is_enabled/0 during declare (#14699)
`rabbit_amqqueue:declare/7` consults the `is_enabled/0` callback of `rabbit_queue_type` before attempting to create a queue. `rabbit_stream_manager` emulates `rabbit_amqqueue:declare/7` rather than calling it directly. To align with the `is_enabled/0` check in `rabbit_amqqueue:declare/7`, `rabbit_stream_manager` needs to check the callback during stream creation.
1 parent cae2b4b commit 1c264fa

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

deps/rabbitmq_stream/src/rabbit_stream_manager.erl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,10 +47,13 @@ create(VirtualHost, Reference, Arguments, Username) ->
4747
StreamQueueArguments = stream_queue_arguments(Arguments),
4848
maybe
4949
ok ?= validate_stream_queue_arguments(StreamQueueArguments),
50+
true ?= rabbit_stream_queue:is_enabled(),
5051
do_create_stream(VirtualHost, Reference, StreamQueueArguments, Username)
5152
else
5253
error ->
5354
{error, validation_failed};
55+
false ->
56+
{error, validation_failed};
5457
{error, _} = Err ->
5558
Err
5659
end.

0 commit comments

Comments
 (0)