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 2022/09/15 12:07:27 UTC
[camel-quarkus] 03/03: Explicitly define the dataSource on JTA itest SQL endpoints due to #4063
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 <ja...@gmail.com>
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")