This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch kamelet-eip in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4b30d8765a760bd3e3bdbfb8eefceb83df35bd24 Author: Claus Ibsen <[email protected]> AuthorDate: Tue Apr 13 13:21:40 2021 +0200 CAMEL-16493: Kamelet EIP --- .../java/org/apache/camel/component/kamelet/KameletAggregateTest.java | 4 ++-- .../java/org/apache/camel/component/kamelet/KameletBasicTest.java | 1 + .../org/apache/camel/component/kamelet/KameletEipAggregateTest.java | 1 - 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletAggregateTest.java b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletAggregateTest.java index ece1c9b..cb27980 100644 --- a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletAggregateTest.java +++ b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletAggregateTest.java @@ -54,12 +54,12 @@ public class KameletAggregateTest extends CamelTestSupport { routeTemplate("my-aggregate") .templateParameter("count") .from("kamelet:source") - .aggregate(constant(true)) + .aggregate(constant(true)) .completionSize("{{count}}") .aggregationStrategy(AggregationStrategies.string(",")) .to("log:aggregate") .to("kamelet:sink") - .end(); + .end(); from("direct:start") .to("kamelet:my-aggregate?count=5") diff --git a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletBasicTest.java b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletBasicTest.java index 4a89418..52f1239 100644 --- a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletBasicTest.java +++ b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletBasicTest.java @@ -28,6 +28,7 @@ import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; public class KameletBasicTest extends CamelTestSupport { + @Test public void canProduceToKamelet() { String body = UUID.randomUUID().toString(); diff --git a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipAggregateTest.java b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipAggregateTest.java index b863453..2aa911e 100644 --- a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipAggregateTest.java +++ b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipAggregateTest.java @@ -53,7 +53,6 @@ public class KameletEipAggregateTest extends CamelTestSupport { .templateParameter("count") .from("kamelet:source") .aggregate(constant(true)) - .parallelProcessing() .completionSize("{{count}}") .aggregationStrategy(AggregationStrategies.string(",")) .to("log:aggregate")
