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

This closes #3025

This commit is contained in:
Clebert Suconic 2020-03-17 14:01:07 -04:00
parent fa4b579baf 395eb1a2bb
commit 176c3e1a00
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/interop/GeneralInteropTest.java
View File

@ -235,13 +235,15 @@ public class GeneralInteropTest extends BasicOpenWireTest {
}
}
Wait.assertEquals(0, queueControl::getDeliveringCount);
message = consumer.receive(5000);
assertNotNull(message);
assertTrue(message instanceof TextMessage);
assertEquals(text + 1, ((TextMessage)message).getText());
message.acknowledge();
Wait.assertEquals(2L, () -> queueControl.getMessagesAcknowledged(), 3000, 100);
Wait.assertEquals(1L, () -> queueControl.getMessagesAcknowledged(), 3000, 100);
Wait.assertEquals(prefetchSize, () -> queueControl.getDeliveringCount(), 30000, 100);
} finally {
connection.close();