davsclaus commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r816471972
##########
File path:
tests/camel-itest/src/test/java/org/apache/camel/itest/tx/JtaRouteTest.java
##########
@@ -38,23 +65,94 @@ protected RouteBuilder createRouteBuilder() throws
Exception {
public void configure() throws Exception {
context.getRegistry().bind("PROPAGATION_REQUIRES_NEW", new
RequiresNewJtaTransactionPolicy());
- from("direct:requires_new")
+ from("direct:split_test")
.transacted("PROPAGATION_REQUIRES_NEW")
+ .to("direct:split");
+
+ from("direct:split")
.split(body()).delimiter("_").to("direct:splitted").end()
- .log("after splitter log which you will never see...")
- .transform().constant("requires_new");
+ .log("after splitter log which you will never see...");
from("direct:splitted").to("mock:splitted");
+
+ from("direct:multicast_test").routeId("r.route1")
+ .log(LoggingLevel.DEBUG, "Entering route: ${routeId}")
+ .transacted()
+ .to("direct:multicast")
+ .log("will never get here");
+
+ from("direct:multicast").routeId("r.route2")
+ .log(LoggingLevel.DEBUG, "Entering route: ${routeId}")
+ .multicast()
+ .to("log:r.test", "direct:route3", "mock:test")
+ .end();
+
+ from("direct:route3").routeId("r.route3")
+ .log(LoggingLevel.DEBUG, "Entering route: ${routeId}");
Review comment:
I think we should add a inlined processor that tests that the exchange
is transacted, in all of these sub routes (not only here). This will help test
the copied exchanges are marked as transactional.
Something ala
.process(e -> Assertions.assertTrue(e.isTransacted())
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
