Skip to content

Commit 67285d6

Browse files
Merge pull request #9827 from rabbitmq/fix-mqtt-khepri-flake
Fix test flake session_takeover_v3_v5
2 parents d3c14a4 + a5f4317 commit 67285d6

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1581,7 +1581,8 @@ drop_local(QNames, #state{subscriptions = Subs,
15811581
"qos", _:1/binary >>},
15821582
#{binding_keys := BindingKeys}})
15831583
when Vhost0 =:= Vhost andalso
1584-
ClientId0 =:= ClientId ->
1584+
ClientId0 =:= ClientId andalso
1585+
map_size(BindingKeys) > 0 ->
15851586
rabbit_misc:maps_any(
15861587
fun(BKey, true) ->
15871588
TopicFilter = amqp_to_mqtt(BKey),

0 commit comments

Comments
 (0)