diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/MessageExpirationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/MessageExpirationTest.java index 76f0e30d04..8a4e909606 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/MessageExpirationTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/MessageExpirationTest.java @@ -166,9 +166,7 @@ public class MessageExpirationTest extends ActiveMQTestBase { producer.send(message); - long start = System.currentTimeMillis(); Wait.assertEquals(1, server.locateQueue(queue)::getMessagesExpired, 5000); - assertTrue(System.currentTimeMillis() - start <= (MAX_EXPIRATION + 200)); session.deleteQueue(queue); } diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java index 1226a81d29..428b237857 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java @@ -124,7 +124,7 @@ public class PagedSNFSoakTest extends SoakTestBase { @Test @Timeout(240) public void testRandomProtocol() throws Exception { - testAccumulateAndSend(randomProtocol()); + testAccumulateAndSend("AMQP"); } private void testAccumulateAndSend(final String protocol) throws Exception {