You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/08/01 13:54:24 UTC
[camel] 03/04: CAMEL-13801 - Fixed CS for Camel-Spring
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 71b1f6c27635cdb5150a0c680a7adb3e258d6b63
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Aug 1 15:52:34 2019 +0200
CAMEL-13801 - Fixed CS for Camel-Spring
---
.../camel/spring/SpringMDCTransactedTest.java | 52 +++++++++-------------
1 file changed, 21 insertions(+), 31 deletions(-)
diff --git a/components/camel-spring/src/test/java/org/apache/camel/spring/SpringMDCTransactedTest.java b/components/camel-spring/src/test/java/org/apache/camel/spring/SpringMDCTransactedTest.java
index f357177..cd82347 100644
--- a/components/camel-spring/src/test/java/org/apache/camel/spring/SpringMDCTransactedTest.java
+++ b/components/camel-spring/src/test/java/org/apache/camel/spring/SpringMDCTransactedTest.java
@@ -30,7 +30,7 @@ import org.slf4j.MDC;
public class SpringMDCTransactedTest extends CamelTestSupport {
- @Override
+ @Override
protected Registry createCamelRegistry() throws Exception {
Registry result = new SimpleRegistry();
result.bind("NOOP-TX", new NoopPlatformTransactionManager());
@@ -55,39 +55,29 @@ public class SpringMDCTransactedTest extends CamelTestSupport {
// enable MDC
context.setUseMDCLogging(true);
- from("direct:a").routeId("route-a")
- .transacted()
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- assertEquals("route-a", MDC.get("camel.routeId"));
- assertEquals(exchange.getExchangeId(), MDC.get("camel.exchangeId"));
- assertEquals(exchange.getIn().getMessageId(), MDC.get("camel.messageId"));
- }
- })
- .to("log:foo-before")
- .to("direct:b")
- .to("log:foo-after")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- assertEquals("route-a", MDC.get("camel.routeId"));
- assertEquals(exchange.getExchangeId(), MDC.get("camel.exchangeId"));
- assertEquals(exchange.getIn().getMessageId(), MDC.get("camel.messageId"));
- }
- });
+ from("direct:a").routeId("route-a").transacted().process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ assertEquals("route-a", MDC.get("camel.routeId"));
+ assertEquals(exchange.getExchangeId(), MDC.get("camel.exchangeId"));
+ assertEquals(exchange.getIn().getMessageId(), MDC.get("camel.messageId"));
+ }
+ }).to("log:foo-before").to("direct:b").to("log:foo-after").process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ assertEquals("route-a", MDC.get("camel.routeId"));
+ assertEquals(exchange.getExchangeId(), MDC.get("camel.exchangeId"));
+ assertEquals(exchange.getIn().getMessageId(), MDC.get("camel.messageId"));
+ }
+ });
- from("direct:b").routeId("route-b")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- assertEquals("route-b", MDC.get("camel.routeId"));
- assertEquals(exchange.getExchangeId(), MDC.get("camel.exchangeId"));
- assertEquals(exchange.getIn().getMessageId(), MDC.get("camel.messageId"));
- }
- })
- .to("log:bar")
- .to("mock:result");
+ from("direct:b").routeId("route-b").process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ assertEquals("route-b", MDC.get("camel.routeId"));
+ assertEquals(exchange.getExchangeId(), MDC.get("camel.exchangeId"));
+ assertEquals(exchange.getIn().getMessageId(), MDC.get("camel.messageId"));
+ }
+ }).to("log:bar").to("mock:result");
}
};
}
-
}