Skip to content

Commit d309ec9

Browse files
authored
Merge pull request #12694 from rabbitmq/mqtt_flake_will_delay_session_takeover
Fix flake will_delay_session_takeover
2 parents ca70f20 + ae42372 commit d309ec9

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

deps/rabbitmq_mqtt/test/v5_SUITE.erl

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1470,7 +1470,14 @@ will_delay_session_takeover(Config) ->
14701470
after 1000 -> ct:fail("server did not disconnect us")
14711471
end || _ <- Clients],
14721472

1473-
ok = expect_publishes(Sub, Topic, [<<"will-3a">>, <<"will-4a">>]),
1473+
receive {publish, #{client_pid := Sub,
1474+
payload := <<"will-3a">>}} -> ok
1475+
after 5000 -> ct:fail({missing_msg, ?LINE})
1476+
end,
1477+
receive {publish, #{client_pid := Sub,
1478+
payload := <<"will-4a">>}} -> ok
1479+
after 5000 -> ct:fail({missing_msg, ?LINE})
1480+
end,
14741481
assert_nothing_received(),
14751482

14761483
[ok = emqtt:disconnect(C) || C <- [Sub, C1b, C2b, C3b, C4b]].

0 commit comments

Comments
 (0)