[camel] branch main updated: CAMEL-17110: Added unit test

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 718ea6a  CAMEL-17110: Added unit test
718ea6a is described below

commit 718ea6a0d78f27b1c0bcd212e0d53c6b3060b914
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed Oct 20 13:10:18 2021 +0200

    CAMEL-17110: Added unit test
---
 ...IssueTest.java => KameletConsumerUoWIssueTest.java} | 18 +++++++++---------
 .../camel/component/kamelet/KameletUoWIssueTest.java   |  2 +-
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
 
b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletConsumerUoWIssueTest.java
similarity index 81%
copy from 
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
copy to 
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletConsumerUoWIssueTest.java
index e38eeef..bb9c1bd 100644
--- 
a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
+++ 
b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletConsumerUoWIssueTest.java
@@ -25,13 +25,13 @@ import org.apache.camel.support.SynchronizationAdapter;
 import org.apache.camel.test.junit5.CamelTestSupport;
 import org.junit.jupiter.api.Test;
 
-public class KameletUoWIssueTest extends CamelTestSupport {
+public class KameletConsumerUoWIssueTest extends CamelTestSupport {
 
     @Test
     public void testUoW() throws Exception {
-        getMockEndpoint("mock:foo").expectedBodiesReceived("A", "Done");
+        getMockEndpoint("mock:foo").expectedBodiesReceived("1", "Done");
 
-        template.sendBody("direct:foo", "A");
+        context.getRouteController().startAllRoutes();
 
         assertMockEndpointsSatisfied();
     }
@@ -47,9 +47,9 @@ public class KameletUoWIssueTest extends CamelTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                routeTemplate("broker")
-                        .templateParameter("queue")
-                        .from("kamelet:source")
+                routeTemplate("tick")
+                        .from("timer:tick?repeatCount=1&delay=-1")
+                        .setBody().exchangeProperty(Exchange.TIMER_COUNTER)
                         .process(new Processor() {
                             @Override
                             public void process(Exchange exchange) throws 
Exception {
@@ -61,10 +61,10 @@ public class KameletUoWIssueTest extends CamelTestSupport {
                                     }
                                 });
                             }
-                        }).to("mock:{{queue}}");
+                        }).to("kamelet:sink");
 
-                from("direct:foo")
-                        .kamelet("broker?queue=foo");
+                from("kamelet:tick").noAutoStartup().routeId("tick")
+                        .to("mock:foo");
             }
         };
     }
diff --git 
a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
 
b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
index e38eeef..d418f48 100644
--- 
a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
+++ 
b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletUoWIssueTest.java
@@ -64,7 +64,7 @@ public class KameletUoWIssueTest extends CamelTestSupport {
                         }).to("mock:{{queue}}");
 
                 from("direct:foo")
-                        .kamelet("broker?queue=foo");
+                        .to("kamelet:broker?queue=foo");
             }
         };
     }