[camel] 02/02: CAMEL-16066: Lambda DSL you can use expressions via the this instance

[da...@apache.org]

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 <cl...@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();