Skip to content

Commit aa44982

Browse files
authored
Merge pull request #12695 from rabbitmq/mergify/bp/v4.0.x/pr-12694
Fix flake will_delay_session_takeover (backport #12694)
2 parents 6d4e1c2 + 6470188 commit aa44982

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
@@ -1480,7 +1480,14 @@ will_delay_session_takeover(Config) ->
14801480
after 1000 -> ct:fail("server did not disconnect us")
14811481
end || _ <- Clients],
14821482

1483-
ok = expect_publishes(Sub, Topic, [<<"will-3a">>, <<"will-4a">>]),
1483+
receive {publish, #{client_pid := Sub,
1484+
payload := <<"will-3a">>}} -> ok
1485+
after 5000 -> ct:fail({missing_msg, ?LINE})
1486+
end,
1487+
receive {publish, #{client_pid := Sub,
1488+
payload := <<"will-4a">>}} -> ok
1489+
after 5000 -> ct:fail({missing_msg, ?LINE})
1490+
end,
14841491
assert_nothing_received(),
14851492

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

0 commit comments

Comments
 (0)