This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5cb42db2eb8438a505cae0804fd9f47cc9195a70 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Jan 21 14:28:11 2021 +0100 CAMEL-16066: Lambda DSL you can use expressions via the this instance --- .../apache/camel/processor/LambdaRouteBuilderTest.java | 18 ++++++++++++++++++ .../processor/interceptor/AdviceWithLambdaTest.java | 15 +++++++++++++++ 2 files changed, 33 insertions(+) diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java index adae3a6..66bf0bc 100644 --- a/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java @@ -72,4 +72,22 @@ public class LambdaRouteBuilderTest extends ContextTestSupport { assertMockEndpointsSatisfied(); } + @Test + public void testLambdaSimple() throws Exception { + assertEquals(0, context.getRoutesSize()); + + RouteBuilder.addRoutes(context, rb -> rb.from("direct:start").transform(rb.simple("Hello ${body}")).to("mock:result")); + + context.start(); + + assertEquals(1, context.getRoutesSize()); + + MockEndpoint mock = getMockEndpoint("mock:result"); + mock.expectedBodiesReceived("Hello World"); + + template.sendBody("direct:start", "World"); + + assertMockEndpointsSatisfied(); + } + } diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java index e63d752..d61d5ce 100644 --- a/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java @@ -54,6 +54,21 @@ public class AdviceWithLambdaTest extends ContextTestSupport { // END SNIPPET: e1 @Test + public void testAdvisedSimple() throws Exception { + AdviceWith.adviceWith(context, null, a -> { + a.interceptSendToEndpoint("mock:foo").skipSendToOriginalEndpoint().transform(a.simple("Hello ${body}")).to("log:foo").to("mock:advised"); + }); + + getMockEndpoint("mock:foo").expectedMessageCount(0); + getMockEndpoint("mock:advised").expectedBodiesReceived("Hello World"); + getMockEndpoint("mock:result").expectedBodiesReceived("Hello World"); + + template.sendBody("direct:start", "World"); + + assertMockEndpointsSatisfied(); + } + + @Test public void testAdvisedNoLog() throws Exception { AdviceWith.adviceWith(context, null, false, a -> { a.weaveByToUri("mock:result").remove();