You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2026/01/02 13:49:16 UTC
(camel-quarkus) 18/30: doubled timeouts in jta.testTx - to test on ubuntuclear
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit e3345e5758e8a7864188952b217f2f770973dced
Author: Jiri Ondrusek <on...@gmail.com>
AuthorDate: Mon Dec 8 09:28:29 2025 +0100
doubled timeouts in jta.testTx - to test on ubuntuclear
---
.../apache/camel/quarkus/component/jta/it/JtaTest.java | 16 +++++++++++++---
1 file changed, 13 insertions(+), 3 deletions(-)
diff --git a/integration-tests/jta/src/test/java/org/apache/camel/quarkus/component/jta/it/JtaTest.java b/integration-tests/jta/src/test/java/org/apache/camel/quarkus/component/jta/it/JtaTest.java
index 976e26fae4..885edfa6df 100644
--- a/integration-tests/jta/src/test/java/org/apache/camel/quarkus/component/jta/it/JtaTest.java
+++ b/integration-tests/jta/src/test/java/org/apache/camel/quarkus/component/jta/it/JtaTest.java
@@ -33,12 +33,15 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import static org.hamcrest.Matchers.is;
@QuarkusTest
@QuarkusTestResource(H2DatabaseTestResource.class)
class JtaTest {
+ private final Logger LOG = LoggerFactory.getLogger(JtaTest.class);
@Test
public void testNoTx() {
@@ -149,10 +152,12 @@ class JtaTest {
@ParameterizedTest
@ValueSource(strings = { "jdbc", "jdbcRollback", "sqltx", "sqltxRollback" })
public void testTx(String endpoint) throws SQLException {
+ LOG.info("Starting test for: " + endpoint);
final String msg = endpoint + ":" + UUID.randomUUID().toString().replace("-", "");
assertDBRows(endpoint);
- RestAssured.get("/jta/mock/" + endpoint + "/0/1000")
+ LOG.info("DB is empty.");
+ RestAssured.get("/jta/mock/" + endpoint + "/0/10000")
.then()
.statusCode(200)
.body(Matchers.is(""));
@@ -164,13 +169,16 @@ class JtaTest {
.then()
.statusCode(201)
.body(is(msg + " added"));
+ LOG.info("Inserted " + msg);
// One row inserted
assertDBRows(endpoint, msg);
- RestAssured.get("/jta/mock/" + endpoint + "/1/15000")
+ LOG.info("DB contains 1 msg");
+ RestAssured.get("/jta/mock/" + endpoint + "/1/30000")
.then()
.statusCode(200)
.body(Matchers.is(msg));
+ LOG.info("Inserted 2nd message " + msg);
RestAssured.given()
.contentType(ContentType.TEXT)
@@ -178,10 +186,12 @@ class JtaTest {
.post("/jta/route/" + endpoint)
.then()
.statusCode(500);
+ LOG.info("Rollback triggered");
// Should still have the original row as the other insert attempt was rolled back
assertDBRows(endpoint, msg);
- RestAssured.get("/jta/mock/" + endpoint + "/1/15000")
+ LOG.info("DB contains only 1 msg");
+ RestAssured.get("/jta/mock/" + endpoint + "/1/30000")
.then()
.statusCode(200)
.body(Matchers.is(msg));