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 #3027

This commit is contained in:
Clebert Suconic 2020-03-17 16:23:05 -04:00
parent 9ba0621124 974a80002a
commit 04572f9915
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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