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 <[email protected]>
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
+}