diff options
| -rw-r--r-- | test/single_active_consumer_SUITE.erl | 33 |
1 files changed, 24 insertions, 9 deletions
diff --git a/test/single_active_consumer_SUITE.erl b/test/single_active_consumer_SUITE.erl index e0e48fb8d7..4e622dd894 100644 --- a/test/single_active_consumer_SUITE.erl +++ b/test/single_active_consumer_SUITE.erl @@ -22,6 +22,8 @@ -compile(export_all). +-define(TIMEOUT, 30000). + all() -> [ {group, classic_queue}, {group, quorum_queue} @@ -114,8 +116,9 @@ all_messages_go_to_one_consumer(Config) -> ?assertEqual(2, maps:size(MessagesPerConsumer)), ?assertEqual(MessageCount, maps:get(CTag1, MessagesPerConsumer)), ?assertEqual(0, maps:get(CTag2, MessagesPerConsumer)) - after 1000 -> - throw(failed) + after ?TIMEOUT -> + flush(), + throw(failed) end, amqp_connection:close(C), @@ -169,8 +172,9 @@ fallback_to_another_consumer_when_first_one_is_cancelled(Config) -> ?assertEqual(MessageCount div 2, maps:get(FirstActiveConsumer, MessagesPerConsumer)), ?assertEqual(MessageCount div 2 - 1, maps:get(SecondActiveConsumer, MessagesPerConsumer)), ?assertEqual(1, maps:get(LastActiveConsumer, MessagesPerConsumer)) - after 1000 -> - throw(failed) + after ?TIMEOUT -> + flush(), + throw(failed) end, amqp_connection:close(C), @@ -319,9 +323,10 @@ consume({Parent, {MessagesPerConsumer, MessageCount}, CountDown}) -> consume({Parent, {MessagesPerConsumer, MessageCount}, CountDown}); _ -> consume({Parent, {MessagesPerConsumer, MessageCount}, CountDown}) - after 10000 -> - Parent ! {consumer_timeout, {MessagesPerConsumer, MessageCount}}, - exit(consumer_timeout) + after ?TIMEOUT -> + Parent ! {consumer_timeout, {MessagesPerConsumer, MessageCount}}, + flush(), + exit(consumer_timeout) end. consume_results() -> @@ -332,8 +337,9 @@ consume_results() -> {MessagesPerConsumer, MessageCount}; _ -> consume_results() - after 1000 -> - throw(failed) + after ?TIMEOUT -> + flush(), + throw(failed) end. wait_for_messages(ExpectedCount) -> @@ -365,3 +371,12 @@ receive_deliver() -> after 5000 -> exit(deliver_timeout) end. + +flush() -> + receive + Msg -> + ct:pal("flushed: ~w~n", [Msg]), + flush() + after 10 -> + ok + end. |