[activemq-artemis] branch master updated: ARTEMIS-3135 Fixing intermittent test failure

[cl...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 66040b0  ARTEMIS-3135 Fixing intermittent test failure
66040b0 is described below

commit 66040b009c5f3bedd43395ac7fb0e9ebda790e0f
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Tue Feb 23 13:59:24 2021 -0500

    ARTEMIS-3135 Fixing intermittent test failure
---
 .../activemq/artemis/tests/integration/amqp/JMXManagementTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
index fd6a781..128636a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
@@ -148,13 +148,13 @@ public class JMXManagementTest extends JMSClientTestSupport {
          SimpleString queue = new SimpleString(getQueueName());
          QueueControl queueControl = createManagementControl(queue, queue);
 
-         Assert.assertEquals(2, queueControl.getMessageCount());
+         Wait.assertEquals(2, queueControl::getMessageCount);
 
          JsonArray array = JsonUtil.readJsonArray(queueControl.getFirstMessageAsJSON());
          JsonObject object = (JsonObject) array.get(0);
          queueControl.removeMessage(object.getJsonNumber("messageID").longValue());
 
-         Wait.assertEquals(1L, queueControl::getMessageCount);
+         Wait.assertEquals(1, queueControl::getMessageCount);
 
          Map<String, Object>[] messages = queueControl.listMessages("");
          Assert.assertEquals(1, messages.length);