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/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 60cbd99e5f ARTEMIS-5379 small tweaks on test
60cbd99e5f is described below
commit 60cbd99e5f2a7e71423cb5c9e7f9a089afe23e8c
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Apr 3 16:33:08 2025 -0400
ARTEMIS-5379 small tweaks on test
AMQP was not really being used
---
.../activemq/artemis/tests/soak/paging/ValidatePageTXTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidatePageTXTest.java
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidatePageTXTest.java
index 57356c421d..49e701bdaa 100644
---
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidatePageTXTest.java
+++
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidatePageTXTest.java
@@ -191,13 +191,13 @@ public class ValidatePageTXTest extends SoakTestBase {
logger.debug("Waiting some time");
Thread.sleep(100);
+
running.set(false);
- logger.debug("running set to false");
+ logger.debug("running set to false, waiting latchDone now");
assertTrue(latchDone.await(300, TimeUnit.SECONDS));
- logger.debug("latch done is done.. shutting down executor");
-
+ logger.debug("shutting down executor");
executorService.shutdownNow();
assertTrue(executorService.awaitTermination(60, TimeUnit.SECONDS));
@@ -281,7 +281,7 @@ public class ValidatePageTXTest extends SoakTestBase {
xasession = xaConnection.createXASession();
session = xasession;
} else {
- factory = CFUtil.createConnectionFactory("CORE", uri);
+ factory = CFUtil.createConnectionFactory(protocol, uri);
connection = factory.createConnection();
session = connection.createSession(true,
Session.SESSION_TRANSACTED);
}
@@ -330,7 +330,7 @@ public class ValidatePageTXTest extends SoakTestBase {
logger.warn("Exception of the exception on {},
message={}", threadID, e2.getMessage(), e2);
}
}
- if (e.getCause() != null && e.getCause() instanceof
ActiveMQDuplicateIdException) {
+ if (e.getMessage() != null &&
e.getMessage().contains("Duplicate message detected") || e.getCause() != null
&& e.getCause() instanceof ActiveMQDuplicateIdException) {
logger.debug("duplicateID exception dupID={} error={},
threadID={}, storing the duplicateID as it is fine", dupID, e.getMessage(),
threadID);
dupList.add(dupID);
dupID = String.valueOf(sequenceGenerator.incrementAndGet());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
