This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 9755ff3f885908858ff12cd0f42b058299b793d3 Author: James Netherton <[email protected]> AuthorDate: Thu Sep 15 09:45:39 2022 +0100 Explicitly define the dataSource on JTA itest SQL endpoints due to #4063 --- .../java/org/apache/camel/quarkus/component/jta/it/JtaRoutes.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/integration-tests/jta/src/main/java/org/apache/camel/quarkus/component/jta/it/JtaRoutes.java b/integration-tests/jta/src/main/java/org/apache/camel/quarkus/component/jta/it/JtaRoutes.java index dec524f2f4..3ccd650850 100644 --- a/integration-tests/jta/src/main/java/org/apache/camel/quarkus/component/jta/it/JtaRoutes.java +++ b/integration-tests/jta/src/main/java/org/apache/camel/quarkus/component/jta/it/JtaRoutes.java @@ -86,7 +86,9 @@ public class JtaRoutes extends RouteBuilder { .transacted() .setHeader("message", body()) .to("jms:queue:sqltx?connectionFactory=#xaConnectionFactory&disableReplyTo=true") - .to("sql:insert into example(message, origin) values (:#message, 'sqltx')") + // TODO: Remove the explicit dataSource option + // https://github.com/apache/camel-quarkus/issues/4063 + .to("sql:insert into example(message, origin) values (:#message, 'sqltx')?dataSource=#camel-ds") .choice() .when(header("message").startsWith("rollback")) .log("Failing forever with exception") @@ -103,7 +105,9 @@ public class JtaRoutes extends RouteBuilder { .transacted() .setHeader("message", body()) .to("jms:queue:sqltxRollback?connectionFactory=#xaConnectionFactory&disableReplyTo=true") - .to("sql:insert into example(message, origin) values (:#message, 'sqltxRollback')") + // TODO: Remove the explicit dataSource option + // https://github.com/apache/camel-quarkus/issues/4063 + .to("sql:insert into example(message, origin) values (:#message, 'sqltxRollback')?dataSource=#camel-ds") .choice() .when(header("message").startsWith("rollback")) .log("Rolling back after rollback message")
