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 2020/06/23 00:42:55 UTC
[activemq-artemis] branch master updated: NO-JIRA fixing
Intermittent failure on 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 c54ff4c NO-JIRA fixing Intermittent failure on test
c54ff4c is described below
commit c54ff4c85909be2b722294f24e057b845fc6fc67
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Mon Jun 22 20:42:25 2020 -0400
NO-JIRA fixing Intermittent failure on test
---
.../tests/integration/server/AutoCreateDeadLetterResourcesTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AutoCreateDeadLetterResourcesTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AutoCreateDeadLetterResourcesTest.java
index 484b83a..9651b0e 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AutoCreateDeadLetterResourcesTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AutoCreateDeadLetterResourcesTest.java
@@ -240,14 +240,14 @@ public class AutoCreateDeadLetterResourcesTest extends ActiveMQTestBase {
ClientProducer producer = addClientProducer(session.createProducer(moveFromAddress));
producer.send(session.createMessage(true));
producer.close();
-
+ Wait.assertEquals(1L, server.locateQueue(moveFromQueue)::getMessageCount, 2000, 100);
server.locateQueue(moveFromQueue).moveReferences(null, addressA, null);
- Wait.assertEquals(1L, () -> server.locateQueue(queueA).getMessageCount(), 2000, 100);
+ Wait.assertEquals(1L, server.locateQueue(queueA)::getMessageCount, 2000, 100);
triggerDlaDelivery();
- Wait.assertTrue(() -> server.locateQueue(dlqName).getMessageCount() == 1, 2000, 100);
+ Wait.assertEquals(1L, server.locateQueue(dlqName)::getMessageCount, 2000, 100);
ClientConsumer consumer = session.createConsumer(dlqName);
session.start();