You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2019/10/11 13:06:39 UTC
[activemq-artemis] branch master updated: NO-JIRA Replacing
assertEquals(queue.getCount) by Wait.asserEquals on a test
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 <cl...@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();
}