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 2017/11/21 15:33:18 UTC
activemq-artemis git commit: ARTEMIS-1513 Fix intermittent failure
Repository: activemq-artemis
Updated Branches:
refs/heads/master accec57e5 -> 16d9b191a
ARTEMIS-1513 Fix intermittent failure
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/16d9b191
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/16d9b191
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/16d9b191
Branch: refs/heads/master
Commit: 16d9b191a1ac15ac0c335c9c79b145c7e9caea93
Parents: accec57
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Nov 21 10:31:42 2017 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Nov 21 10:32:03 2017 -0500
----------------------------------------------------------------------
.../tests/integration/amqp/AmqpSendReceiveTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/16d9b191/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpSendReceiveTest.java
----------------------------------------------------------------------
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 a35541c..76f1353 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
@@ -133,12 +133,12 @@ public class AmqpSendReceiveTest extends AmqpClientTestSupport {
AmqpReceiver receiver = session.createReceiver(getQueueName(1));
Queue queueView = getProxyToQueue(getQueueName());
- assertEquals(1, queueView.getConsumerCount());
- assertEquals(0, queueView.getMessageCount());
+ Wait.assertEquals(1, queueView::getConsumerCount);
+ Wait.assertEquals(0, queueView::getMessageCount);
queueView = getProxyToQueue(getQueueName(1));
- assertEquals(1, queueView.getConsumerCount());
- assertEquals(1, queueView.getMessageCount());
+ Wait.assertEquals(1, queueView::getConsumerCount);
+ Wait.assertEquals(1, queueView::getMessageCount);
receiver.flow(1);
AmqpMessage message = receiver.receive(5, TimeUnit.SECONDS);
@@ -146,7 +146,7 @@ public class AmqpSendReceiveTest extends AmqpClientTestSupport {
message.accept();
receiver.close();
- assertEquals(0, queueView.getMessageCount());
+ Wait.assertEquals(0, queueView::getMessageCount);
connection.close();
}