This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 8629d5573f NO-JIRA Fixing intermittent failure on test
8629d5573f is described below
commit 8629d5573f1bebf9ae7dfb2d15f1cb5dab803bec
Author: Clebert Suconic <[email protected]>
AuthorDate: Tue Apr 15 22:11:11 2025 -0400
NO-JIRA Fixing intermittent failure on test
---
.../activemq/artemis/tests/smoke/logging/AuditLoggerResourceTest.java | 3 ++-
.../artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java | 3 +++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git
a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerResourceTest.java
b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerResourceTest.java
index 86b6007648..be080cac57 100644
---
a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerResourceTest.java
+++
b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerResourceTest.java
@@ -42,6 +42,7 @@ import
org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConne
import
org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnectionFactory;
import org.apache.activemq.artemis.tests.util.CFUtil;
import org.apache.activemq.artemis.utils.RandomUtil;
+import org.apache.activemq.artemis.utils.Wait;
import org.fusesource.mqtt.client.BlockingConnection;
import org.fusesource.mqtt.client.MQTT;
import org.junit.jupiter.api.Test;
@@ -125,7 +126,7 @@ public class AuditLoggerResourceTest extends
AuditLoggerTestBase {
assertTrue(findLogRecord(getAuditLog(), "AMQ601767: " + protocol + "
connection"));
s.close();
connection.close();
- assertTrue(findLogRecord(getAuditLog(), "AMQ601768: " + protocol + "
connection"));
+ Wait.assertTrue(() -> findLogRecord(getAuditLog(), "AMQ601768: " +
protocol + " connection"), 5000, 100);
}
@Test
diff --git
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java
index 624291cd2e..1f33785212 100644
---
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java
+++
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java
@@ -43,6 +43,7 @@ import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
public class ReplicationFlowControlTest extends SoakTestBase {
@@ -100,11 +101,13 @@ public class ReplicationFlowControlTest extends
SoakTestBase {
}
@Test
+ @Timeout(value = 5, unit = TimeUnit.MINUTES, threadMode =
Timeout.ThreadMode.SEPARATE_THREAD)
public void testPageWhileSynchronizingReplica() throws Exception {
internalTest(false);
}
@Test
+ @Timeout(value = 5, unit = TimeUnit.MINUTES, threadMode =
Timeout.ThreadMode.SEPARATE_THREAD)
public void testPageWhileSyncFailover() throws Exception {
internalTest(true);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
