This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/artemis.git
The following commit(s) were added to refs/heads/main by this push:
new bcd7b66c36 NO-JIRA fixing intermittent failure
bcd7b66c36 is described below
commit bcd7b66c366e8fccec0ecdbf864e2a55073de3f6
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Dec 11 22:49:30 2025 -0500
NO-JIRA fixing intermittent failure
---
.../activemq/artemis/tests/integration/amqp/connect/AckManagerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AckManagerTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AckManagerTest.java
index 15761c5d04..c237b0de43 100644
---
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AckManagerTest.java
+++
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AckManagerTest.java
@@ -183,7 +183,6 @@ public class AckManagerTest extends ActiveMQTestBase {
for (int repeat = 0; repeat < 2; repeat++) {
logger.info("Repeating {}", repeat);
AckManager ackManager = AckManagerProvider.getManager(server1);
- ackManager.start();
Map<SimpleString, LongObjectHashMap<JournalHashMap<AckRetry,
AckRetry, Queue>>> sortedRetries = ackManager.sortRetries();
@@ -198,6 +197,7 @@ public class AckManagerTest extends ActiveMQTestBase {
assertEquals(numberOfAcksC1, acksOnc1s1.size());
assertEquals(numberOfAcksC2, acksOnc2s2.size());
+ ackManager.start();
Wait.assertEquals(numberOfMessages, c1s1::getMessageCount);
Wait.assertEquals(numberOfMessages, c2s2::getMessageCount);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
