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 2018/03/08 18:47:51 UTC
activemq-artemis git commit: NO-JIRA Fix intermittent failure
Repository: activemq-artemis
Updated Branches:
refs/heads/master d30c463a7 -> 80c71fea6
NO-JIRA 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/80c71fea
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/80c71fea
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/80c71fea
Branch: refs/heads/master
Commit: 80c71fea63efdd360dfe92f2c4d078d85485ee66
Parents: d30c463
Author: Clebert Suconic <cl...@apache.org>
Authored: Thu Mar 8 13:36:17 2018 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Mar 8 13:36:17 2018 -0500
----------------------------------------------------------------------
.../artemis/tests/integration/amqp/AmqpSendReceiveTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/80c71fea/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 76f1353..fc4d9ad 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
@@ -401,7 +401,7 @@ public class AmqpSendReceiveTest extends AmqpClientTestSupport {
sender.close();
Queue queue = getProxyToQueue(getQueueName());
- assertEquals(MSG_COUNT, queue.getMessageCount());
+ Wait.assertEquals(MSG_COUNT, queue::getMessageCount);
AmqpReceiver receiver1 = session.createReceiver(getQueueName());
receiver1.flow(MSG_COUNT);