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/artemis.git
commit 99741ad4a31c6fd70a13abb484afa98a97e3f30d Author: Clebert Suconic <[email protected]> AuthorDate: Tue Mar 3 12:11:52 2026 -0500 NO-JIRA raising timeouts on tests --- .../smoke/failover/OpenWireSharedStoreFailoverSmokeTest.java | 2 +- .../soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/failover/OpenWireSharedStoreFailoverSmokeTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/failover/OpenWireSharedStoreFailoverSmokeTest.java index 793c74763b..44669d31b3 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/failover/OpenWireSharedStoreFailoverSmokeTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/failover/OpenWireSharedStoreFailoverSmokeTest.java @@ -218,7 +218,7 @@ public class OpenWireSharedStoreFailoverSmokeTest extends SmokeTestBase { assertEquals(NUMBER_OF_MESSAGES, duplicateSize, "Should have confirmed all messages (with retries during failover)"); SimpleManagement management = new SimpleManagement("tcp://localhost:61617", null, null); - Wait.waitFor(() -> management.getMessageCountOnQueue(QUEUE_NAME) >= duplicateIDs.size(), 5000, 100); + Wait.waitFor(() -> management.getMessageCountOnQueue(QUEUE_NAME) >= duplicateIDs.size()); long numberOfMessages = management.getMessageCountOnQueue(QUEUE_NAME); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java index 7b538ed106..a16acbf328 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java @@ -479,10 +479,10 @@ public class ClusteredMirrorSoakTest extends SoakTestBase { sendMessages(connectionFactoryDC1A, queueName, numberOfMessages, 10); - Wait.assertEquals(numberOfMessages, () -> simpleManagementDC1A.getMessageCountOnQueue(queueName), 5000); - Wait.assertEquals(0, () -> simpleManagementDC1B.getMessageCountOnQueue(queueName), 5000); - Wait.assertEquals(numberOfMessages, () -> simpleManagementDC2A.getMessageCountOnQueue(queueName), 5000); - Wait.assertEquals(0, () -> simpleManagementDC2B.getMessageCountOnQueue(queueName), 5000); + Wait.assertEquals(numberOfMessages, () -> simpleManagementDC1A.getMessageCountOnQueue(queueName)); + Wait.assertEquals(0, () -> simpleManagementDC1B.getMessageCountOnQueue(queueName)); + Wait.assertEquals(numberOfMessages, () -> simpleManagementDC2A.getMessageCountOnQueue(queueName)); + Wait.assertEquals(0, () -> simpleManagementDC2B.getMessageCountOnQueue(queueName)); CountDownLatch doneDC2B = startConsumer(executorService, connectionFactoryDC2B, queueName, runningConsumers, errors, receiverCount); Wait.assertEquals(numberOfMessages, receiverCount::get, 30_000); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
