From c6521e0700006de1a00b614768168a0f96c5e28b Mon Sep 17 00:00:00 2001 From: Jiri Danek Date: Tue, 7 Aug 2018 20:02:41 +0200 Subject: [PATCH] NO-JIRA fix flaky tests QueueControlTest#testChangeMessagePriority{,WithInvalidValue} The occasional assertion error is prevented by using Wait.assertEquals where Assert.assertEquals was used previously. --- .../tests/integration/management/QueueControlTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java index 46d360e7ab..9f4a93cfa8 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java @@ -1926,7 +1926,7 @@ public class QueueControlTest extends ManagementTestBase { producer.send(message); QueueControl queueControl = createManagementControl(address, queue); - Assert.assertEquals(1, getMessageCount(queueControl)); + Wait.assertEquals(1, () -> getMessageCount(queueControl)); // the message IDs are set on the server Map[] messages = queueControl.listMessages(null); @@ -1959,7 +1959,7 @@ public class QueueControlTest extends ManagementTestBase { producer.send(message); QueueControl queueControl = createManagementControl(address, queue); - Assert.assertEquals(1, getMessageCount(queueControl)); + Wait.assertEquals(1, () -> getMessageCount(queueControl)); // the message IDs are set on the server Map[] messages = queueControl.listMessages(null);