You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2022/02/25 16:37:58 UTC
[GitHub] [camel] zhfeng opened a new pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
zhfeng opened a new pull request #7040:
URL: https://github.com/apache/camel/pull/7040
…ticast processor
another fix in MultiProcessor.
<!-- Uncomment and fill this section if your PR is not trivial
- [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes.
- [ ] Each commit in the pull request should have a meaningful subject line and body.
- [ ] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue.
- [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why.
- [ ] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically.
Below are the contribution guidelines:
https://github.com/apache/camel/blob/main/CONTRIBUTING.md
-->
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055488742
There are CI for 3.14 and 3.11 branches.
Camel 3.15 onwards are JDK11 only.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r815524876
##########
File path: core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
##########
@@ -910,6 +910,7 @@ protected Integer getExchangeIndex(Exchange exchange) {
for (Processor processor : processors) {
// copy exchange, and do not share the unit of work
Exchange copy = processorExchangeFactory.createCorrelatedCopy(exchange, false);
+ copy.adapt(ExtendedExchange.class).setTransacted(exchange.isTransacted());
Review comment:
Thansk @davsclaus and I will take a look.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r816501477
##########
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:
OK, I get it and is there any way to do similar check with mock endpoint ?
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r816795005
##########
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:
Done
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] jeremyross commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
jeremyross commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1052557604
Doesn't seem to solve the issue when using spring transactions. Not sure if it's supposed to.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1054384887
Thanks @jeremyross for checking it !
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055490227
Though the PR may work with JDK8 .. I frankly may be mistaken. We can see when we backport as you will get CI errors then
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055605525
@davsclaus It works with JDK 8 and I just backport to 3.14.x
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055487473
We removed the CI build for JDK 8 ?
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r816751458
##########
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:
@zhfeng can you work on this so we can get this PR ready and merged and backported as we want to build new releases of Camel LTS versions with this included.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1054076474
Sure, I will do.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] jeremyross commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
jeremyross commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1054382769
@zhfeng ok just tested with my reproducer project and it looks like it does fix the problem.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1054051595
Can you add a test for the Enricher EIP also.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055502455
OK, I will check it with JDK8 locally before backport it to 3.14 and 3.11
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r815288253
##########
File path: core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
##########
@@ -910,6 +910,7 @@ protected Integer getExchangeIndex(Exchange exchange) {
for (Processor processor : processors) {
// copy exchange, and do not share the unit of work
Exchange copy = processorExchangeFactory.createCorrelatedCopy(exchange, false);
+ copy.adapt(ExtendedExchange.class).setTransacted(exchange.isTransacted());
Review comment:
There would be other EIPs such as split etc that would need something similar. Maybe we can set the transacted in the createCorrelatedCopy (however wiretap EIP would need to set it to false as the tap exchange should not be transacted.
So can you look at which other EIPs that use the createCorrelatedCopy API and build unit tests like you have for multicast.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1053762556
@jeremyross yeah, I think it could reslove the issue when using spring transactions.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055486141
Oh, I just missed it.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1053836005
@davsclaus I add a similar fix for RecipientList and Split EIP. This issue only happens when it copies the exchange and sends it to more then one sub-route in the transacted context.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r816759716
##########
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:
@davsclaus yeah, I'm working on it.
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on pull request #7040:
URL: https://github.com/apache/camel/pull/7040#issuecomment-1055481538
Sorry can you make this PR compile with JDK8 also so we can backport this to older branches
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] zhfeng merged pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
zhfeng merged pull request #7040:
URL: https://github.com/apache/camel/pull/7040
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel] davsclaus commented on a change in pull request #7040: CAMEL-17474: camel-core - set transacted when copying exchange in mul…
Posted by GitBox <gi...@apache.org>.
davsclaus commented on a change in pull request #7040:
URL: https://github.com/apache/camel/pull/7040#discussion_r816512270
##########
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:
oh yeah you can do something with onExchangeReceived or what the name is
--
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-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org