Bump test timeouts

in single active consmer test

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.