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 fix intermittent failure, this test failed on local repeat getting a null from immediate

This commit is contained in:
Gary Tully 2024-05-10 11:14:12 +01:00 committed by clebertsuconic
parent e78136b429
commit 23522fd83d
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
View File

@ -210,6 +210,9 @@ public class SlowConsumerTest extends ActiveMQTestBase {
ClientConsumer consumer = addClientConsumer(session.createConsumer(QUEUE)); ClientConsumer consumer = addClientConsumer(session.createConsumer(QUEUE));
session.start(); session.start();
Queue queue = server.locateQueue(QUEUE);
Wait.assertTrue(() -> queue.getDeliveringCount() >= 3 * threshold);
for (int i = 0; i < 3 * threshold; i++) { for (int i = 0; i < 3 * threshold; i++) {
consumer.receiveImmediate().individualAcknowledge(); consumer.receiveImmediate().individualAcknowledge();
} }