timeout

clebertsuconic · Jan 29, 2025 · 0e61a78 · 0e61a78
1 parent c6a0fd0
commit 0e61a78
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...va/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java b/...va/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java
@@ -16,6 +16,7 @@
  */
 package org.apache.activemq.artemis.tests.soak.replicationflow;
 
+import static org.junit.jupiter.api.Assertions.assertTimeout;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.junit.jupiter.api.Assertions.fail;
 
@@ -27,6 +28,7 @@
 import javax.jms.Queue;
 import javax.jms.Session;
 import java.io.File;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -102,12 +104,12 @@ public void after() throws Exception {
 
    @Test
    public void testPageWhileSynchronizingReplica() throws Exception {
-      internalTest(false);
+      assertTimeout(Duration.ofMinutes(2), () -> internalTest(false));
    }
 
    @Test
    public void testPageWhileSyncFailover() throws Exception {
-      internalTest(true);
+      assertTimeout(Duration.ofMinutes(2), () -> internalTest(true));
    }
 
    private void internalTest(boolean failover) throws Exception {