Skip to content

Commit 58b8c12

Browse files
DQT: be extra defensive in a couple more places
References #11541, #12109, #12821, #13837. (cherry picked from commit a8901bc)
1 parent 41e78ea commit 58b8c12

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

deps/rabbit/src/rabbit_amqqueue.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -765,6 +765,7 @@ augment_declare_args(VHost, Durable, Exclusive, AutoDelete, Args0) ->
765765
case vhost:get_metadata(V) of
766766
#{default_queue_type := DefaultQueueType}
767767
when is_binary(DefaultQueueType) andalso
768+
DefaultQueueType =/= <<"undefined">> andalso
768769
not HasQTypeArg ->
769770
update_args_table_with_queue_type(DefaultQueueType, Durable, Exclusive, AutoDelete, Args0);
770771
_ ->

deps/rabbit/src/rabbit_vhost.erl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -713,6 +713,8 @@ i(metadata, VHost) ->
713713
#{default_queue_type => DQT};
714714
M = #{default_queue_type := undefined} ->
715715
M#{default_queue_type => DQT};
716+
M = #{default_queue_type := <<"undefined">>} ->
717+
M#{default_queue_type => DQT};
716718
M = #{default_queue_type := QT} ->
717719
M#{default_queue_type => rabbit_queue_type:short_alias_of(QT)};
718720
M when is_map(M) ->

0 commit comments

Comments
 (0)