Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA fixing Intermittent failure on test

This commit is contained in:
Clebert Suconic 2020-06-22 20:42:25 -04:00
parent d5d7c3d469
commit c54ff4c859
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AutoCreateDeadLetterResourcesTest.java
View File

@ -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();