This is an automated email from the ASF dual-hosted git repository. klease pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push: new 3c0c856f29f CAMEL-19863: fix Kamelet tests using timer (#947) 3c0c856f29f is described below commit 3c0c856f29f4015b4d062bb55e27780c8df39193 Author: klease <38634989+kle...@users.noreply.github.com> AuthorDate: Sat Sep 16 23:50:02 2023 +0200 CAMEL-19863: fix Kamelet tests using timer (#947) Add includeMetadata=true to the timer endpoint. --- .../camel/component/kamelet/springboot/KameletBasicTest.java | 5 ++--- .../camel/component/kamelet/springboot/KameletConsumeOnlyTest.java | 7 ++++--- .../component/kamelet/springboot/KameletConsumerUoWIssueTest.java | 6 +++--- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletBasicTest.java b/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletBasicTest.java index 09f50f8dc6a..766f971b0d8 100644 --- a/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletBasicTest.java +++ b/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletBasicTest.java @@ -65,7 +65,6 @@ public class KameletBasicTest { fluentTemplate.toF("kamelet:setBody/test?bodyValue=%s", body).request(String.class)).isEqualTo(body); } - @Disabled("https://issues.apache.org/jira/browse/CAMEL-19863") @Test public void canConsumeFromKamelet() { assertThat( @@ -107,7 +106,7 @@ public class KameletBasicTest { .setBody().constant("{{bodyValue}}"); routeTemplate("tick") - .from("timer:{{routeId}}?repeatCount=1&delay=-1") + .from("timer:{{routeId}}?repeatCount=1&delay=-1&includeMetadata=true") .setBody().exchangeProperty(Exchange.TIMER_COUNTER) .to("kamelet:sink"); @@ -116,4 +115,4 @@ public class KameletBasicTest { } }; } -} \ No newline at end of file +} diff --git a/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumeOnlyTest.java b/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumeOnlyTest.java index 55859c6646c..7d413b1d178 100644 --- a/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumeOnlyTest.java +++ b/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumeOnlyTest.java @@ -41,7 +41,7 @@ import org.apache.camel.spring.boot.CamelAutoConfiguration; KameletConsumeOnlyTest.class, } ) -@Disabled("https://issues.apache.org/jira/browse/CAMEL-19863") + public class KameletConsumeOnlyTest { @Autowired @@ -65,10 +65,11 @@ public class KameletConsumeOnlyTest { @Override public void configure() { routeTemplate("tick") - .from("timer:{{routeId}}?repeatCount=1&delay=-1") + .from("timer:{{routeId}}?repeatCount=1&delay=-1&includeMetadata=true") .setBody().exchangeProperty(Exchange.TIMER_COUNTER) + .log("Body is ${body}") .to("kamelet:sink"); } }; } -} \ No newline at end of file +} diff --git a/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumerUoWIssueTest.java b/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumerUoWIssueTest.java index 0bde89ba7af..d62090b508b 100644 --- a/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumerUoWIssueTest.java +++ b/components-starter/camel-kamelet-starter/src/test/java/org/apache/camel/component/kamelet/springboot/KameletConsumerUoWIssueTest.java @@ -44,7 +44,7 @@ import org.apache.camel.spring.boot.CamelAutoConfiguration; KameletConsumerUoWIssueTest.class, } ) -@Disabled("https://issues.apache.org/jira/browse/CAMEL-19863") + public class KameletConsumerUoWIssueTest { @Autowired @@ -77,7 +77,7 @@ public class KameletConsumerUoWIssueTest { @Override public void configure() { routeTemplate("tick") - .from("timer:tick?repeatCount=1&delay=-1") + .from("timer:tick?repeatCount=1&delay=-1&includeMetadata=true") .setBody().exchangeProperty(Exchange.TIMER_COUNTER) .process(new Processor() { @Override @@ -97,4 +97,4 @@ public class KameletConsumerUoWIssueTest { } }; } -} \ No newline at end of file +}