[activemq-artemis] branch master updated: NO-JIRA Replacing assertEquals(queue.getCount) by Wait.asserEquals on a test

[clebertsuconic]

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 149e260  NO-JIRA Replacing assertEquals(queue.getCount) by 
Wait.asserEquals on a test
149e260 is described below

commit 149e26075b5dd892446843e7cf3c5a57266e9b65
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Fri Oct 11 08:59:33 2019 -0400

    NO-JIRA Replacing assertEquals(queue.getCount) by Wait.asserEquals on a test
---
 .../activemq/artemis/tests/integration/amqp/AmqpSendReceiveTest.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/AmqpSendReceiveTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpSendReceiveTest.java
index 559364e..dda89ec 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpSendReceiveTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpSendReceiveTest.java
@@ -1045,7 +1045,7 @@ public class AmqpSendReceiveTest extends 
AmqpClientTestSupport {
       AmqpReceiver receiver = session.createReceiver(address);
 
       Queue queueView = getProxyToQueue(address);
-      assertEquals(1, queueView.getMessageCount());
+      Wait.assertEquals(1, queueView::getMessageCount);
 
       receiver.flow(1);
       AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS);
@@ -1053,7 +1053,7 @@ public class AmqpSendReceiveTest extends 
AmqpClientTestSupport {
       assertEquals(expected, received.getAddress());
       receiver.close();
 
-      assertEquals(1, queueView.getMessageCount());
+      Wait.assertEquals(1, queueView::getMessageCount);
 
       connection.close();
    }