This is an automated email from the ASF dual-hosted git repository.
oscerd pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new 99d90a692 chore: Add Citrus integration tests for 10 self-contained
kamelets (#2915)
99d90a692 is described below
commit 99d90a6928113f97e4e13927e15386fcfce24144
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu Jul 9 20:33:01 2026 +0200
chore: Add Citrus integration tests for 10 self-contained kamelets (#2915)
* chore: Add Citrus integration tests for 10 self-contained kamelets
Add Citrus integration tests for kamelets that require no external
services or containers, using the existing CommonIT HTTP mock and
log verification infrastructure:
- cron-source (log-verify: emits scheduled message)
- set-body-action (http-mock: replaces body)
- delay-action (http-mock: message passes through after delay)
- throttle-action (http-mock: message flows through rate limiter)
- simple-filter-action (http-mock: non-matching message passes)
- xj-identity-action (http-mock: JSON-to-XML transform)
- dns-ip-action (log-verify: localhost resolves to 127.0.0.1)
- regex-router-action (log-verify: Kafka topic regex replacement)
- timestamp-router-action (log-verify: topic gets timestamp prefix)
- topic-name-matches-filter-action (log-verify: matching topic passes)
All tests use Camel route YAML format per issue #2873.
Co-Authored-By: Claude Opus 4.6 (1M context) <[email protected]>
Signed-off-by: Andrea Cosentino <[email protected]>
* fix: Use correct Citrus sendResponse YAML structure
The Citrus HTTP sendResponse requires a nested `response:` element
with `status` and `reasonPhrase` properties, not a flat `status`
property directly under `sendResponse`.
Co-Authored-By: Claude Opus 4.6 (1M context) <[email protected]>
Signed-off-by: Andrea Cosentino <[email protected]>
---------
Signed-off-by: Andrea Cosentino <[email protected]>
Co-authored-by: Claude Opus 4.6 (1M context) <[email protected]>
---
.../src/test/java/CommonIT.java | 35 ++++++++++++++++
.../cron/cron-source-route.citrus.it.yaml | 30 ++++++++++++++
.../src/test/resources/cron/cron-source-route.yaml | 28 +++++++++++++
.../delay/delay-action-route.citrus.it.yaml | 46 ++++++++++++++++++++++
.../test/resources/delay/delay-action-route.yaml | 34 ++++++++++++++++
.../dns/dns-ip-action-route.citrus.it.yaml | 30 ++++++++++++++
.../test/resources/dns/dns-ip-action-route.yaml | 30 ++++++++++++++
.../simple-filter-action-route.citrus.it.yaml | 46 ++++++++++++++++++++++
.../filter/simple-filter-action-route.yaml | 34 ++++++++++++++++
.../regex-router-action-route.citrus.it.yaml | 30 ++++++++++++++
.../kafkarouter/regex-router-action-route.yaml | 38 ++++++++++++++++++
.../timestamp-router-action-route.citrus.it.yaml | 30 ++++++++++++++
.../kafkarouter/timestamp-router-action-route.yaml | 41 +++++++++++++++++++
...name-matches-filter-action-route.citrus.it.yaml | 30 ++++++++++++++
.../topic-name-matches-filter-action-route.yaml | 35 ++++++++++++++++
.../setbody/set-body-action-route.citrus.it.yaml | 46 ++++++++++++++++++++++
.../resources/setbody/set-body-action-route.yaml | 34 ++++++++++++++++
.../throttle/throttle-action-route.citrus.it.yaml | 46 ++++++++++++++++++++++
.../resources/throttle/throttle-action-route.yaml | 34 ++++++++++++++++
.../xj/xj-identity-action-route.citrus.it.yaml | 44 +++++++++++++++++++++
.../resources/xj/xj-identity-action-route.yaml | 38 ++++++++++++++++++
21 files changed, 759 insertions(+)
diff --git a/tests/camel-kamelets-itest/src/test/java/CommonIT.java
b/tests/camel-kamelets-itest/src/test/java/CommonIT.java
index 6c3351084..d3f35ae19 100644
--- a/tests/camel-kamelets-itest/src/test/java/CommonIT.java
+++ b/tests/camel-kamelets-itest/src/test/java/CommonIT.java
@@ -103,4 +103,39 @@ public class CommonIT {
public Stream<DynamicTest> counter() {
return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("counter");
}
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> cron() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("cron");
+ }
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> setBody() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("setbody");
+ }
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> delay() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("delay");
+ }
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> throttle() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("throttle");
+ }
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> xj() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("xj");
+ }
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> dns() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("dns");
+ }
+
+ @CitrusTestFactory
+ public Stream<DynamicTest> kafkaRouter() {
+ return
CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("kafkarouter");
+ }
}
diff --git
a/tests/camel-kamelets-itest/src/test/resources/cron/cron-source-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/cron/cron-source-route.citrus.it.yaml
new file mode 100644
index 000000000..5a5ba0319
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/cron/cron-source-route.citrus.it.yaml
@@ -0,0 +1,30 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: cron-source-route-test
+actions:
+ - camel:
+ jbang:
+ run:
+ waitForRunningState: false
+ integration:
+ file: "cron/cron-source-route.yaml"
+ - camel:
+ jbang:
+ verify:
+ integration: "cron-source-route"
+ logMessage: "cron-test-12345"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/cron/cron-source-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/cron/cron-source-route.yaml
new file mode 100644
index 000000000..482d9b2b6
--- /dev/null
+++ b/tests/camel-kamelets-itest/src/test/resources/cron/cron-source-route.yaml
@@ -0,0 +1,28 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "kamelet:cron-source"
+ parameters:
+ schedule: "0/1 * * * * ?"
+ message: "cron-test-12345"
+ steps:
+ - to:
+ uri: "kamelet:log-sink"
+ parameters:
+ showHeaders: true
diff --git
a/tests/camel-kamelets-itest/src/test/resources/delay/delay-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/delay/delay-action-route.citrus.it.yaml
new file mode 100644
index 000000000..569faf74a
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/delay/delay-action-route.citrus.it.yaml
@@ -0,0 +1,46 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: delay-action-route-test
+variables:
+ - name: "test.message"
+ value: "delayed-message-test"
+actions:
+ - camel:
+ jbang:
+ run:
+ integration:
+ file: "delay/delay-action-route.yaml"
+ systemProperties:
+ properties:
+ - name: "test.message"
+ value: "${test.message}"
+ - name: "http.sink.url"
+ value: "http://localhost:${http.server.port}";
+ - http:
+ server: "httpServer"
+ receiveRequest:
+ POST:
+ path: "/result"
+ body:
+ data: "${test.message}"
+ - http:
+ server: "httpServer"
+ sendResponse:
+ response:
+ status: 200
+ reasonPhrase: "OK"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/delay/delay-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/delay/delay-action-route.yaml
new file mode 100644
index 000000000..4b5a6e6bb
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/delay/delay-action-route.yaml
@@ -0,0 +1,34 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "{{test.message}}"
+ - to:
+ uri: "kamelet:delay-action"
+ parameters:
+ milliseconds: 100
+ - to:
+ uri: "kamelet:http-sink"
+ parameters:
+ url: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/dns/dns-ip-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/dns/dns-ip-action-route.citrus.it.yaml
new file mode 100644
index 000000000..efc034888
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/dns/dns-ip-action-route.citrus.it.yaml
@@ -0,0 +1,30 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: dns-ip-action-route-test
+actions:
+ - camel:
+ jbang:
+ run:
+ waitForRunningState: false
+ integration:
+ file: "dns/dns-ip-action-route.yaml"
+ - camel:
+ jbang:
+ verify:
+ integration: "dns-ip-action-route"
+ logMessage: "127.0.0.1"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/dns/dns-ip-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/dns/dns-ip-action-route.yaml
new file mode 100644
index 000000000..4ecb16f39
--- /dev/null
+++ b/tests/camel-kamelets-itest/src/test/resources/dns/dns-ip-action-route.yaml
@@ -0,0 +1,30 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "localhost"
+ - to:
+ uri: "kamelet:dns-ip-action"
+ - to:
+ uri: "kamelet:log-sink"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/filter/simple-filter-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/filter/simple-filter-action-route.citrus.it.yaml
new file mode 100644
index 000000000..8961a0963
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/filter/simple-filter-action-route.citrus.it.yaml
@@ -0,0 +1,46 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: simple-filter-action-route-test
+variables:
+ - name: "test.message"
+ value: "passthrough-message"
+actions:
+ - camel:
+ jbang:
+ run:
+ integration:
+ file: "filter/simple-filter-action-route.yaml"
+ systemProperties:
+ properties:
+ - name: "test.message"
+ value: "${test.message}"
+ - name: "http.sink.url"
+ value: "http://localhost:${http.server.port}";
+ - http:
+ server: "httpServer"
+ receiveRequest:
+ POST:
+ path: "/result"
+ body:
+ data: "${test.message}"
+ - http:
+ server: "httpServer"
+ sendResponse:
+ response:
+ status: 200
+ reasonPhrase: "OK"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/filter/simple-filter-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/filter/simple-filter-action-route.yaml
new file mode 100644
index 000000000..dc29c726b
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/filter/simple-filter-action-route.yaml
@@ -0,0 +1,34 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "{{test.message}}"
+ - to:
+ uri: "kamelet:simple-filter-action"
+ parameters:
+ expression: "${body} == 'DROP_ME'"
+ - to:
+ uri: "kamelet:http-sink"
+ parameters:
+ url: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafkarouter/regex-router-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/regex-router-action-route.citrus.it.yaml
new file mode 100644
index 000000000..3e3841936
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/regex-router-action-route.citrus.it.yaml
@@ -0,0 +1,30 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: regex-router-action-route-test
+actions:
+ - camel:
+ jbang:
+ run:
+ waitForRunningState: false
+ integration:
+ file: "kafkarouter/regex-router-action-route.yaml"
+ - camel:
+ jbang:
+ verify:
+ integration: "regex-router-action-route"
+ logMessage: "prefix-my-topic"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafkarouter/regex-router-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/regex-router-action-route.yaml
new file mode 100644
index 000000000..059d1b121
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/regex-router-action-route.yaml
@@ -0,0 +1,38 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "test-data"
+ - setHeader:
+ name: CamelKafkaTopic
+ constant: "my-topic"
+ - to:
+ uri: "kamelet:regex-router-action"
+ parameters:
+ regex: "(.*)"
+ replacement: "prefix-$1"
+ - to:
+ uri: "kamelet:log-sink"
+ parameters:
+ showHeaders: true
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafkarouter/timestamp-router-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/timestamp-router-action-route.citrus.it.yaml
new file mode 100644
index 000000000..8eaf1493e
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/timestamp-router-action-route.citrus.it.yaml
@@ -0,0 +1,30 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: timestamp-router-action-route-test
+actions:
+ - camel:
+ jbang:
+ run:
+ waitForRunningState: false
+ integration:
+ file: "kafkarouter/timestamp-router-action-route.yaml"
+ - camel:
+ jbang:
+ verify:
+ integration: "timestamp-router-action-route"
+ logMessage: "my-topic-20240703"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafkarouter/timestamp-router-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/timestamp-router-action-route.yaml
new file mode 100644
index 000000000..9a78e8e7a
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/timestamp-router-action-route.yaml
@@ -0,0 +1,41 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "test-data"
+ - setHeader:
+ name: CamelKafkaTopic
+ constant: "my-topic"
+ - setHeader:
+ name: CamelKafkaTimestamp
+ constant: "1720000000000"
+ - to:
+ uri: "kamelet:timestamp-router-action"
+ parameters:
+ topicFormat: "$[topic]-$[timestamp]"
+ timestampFormat: "yyyyMMdd"
+ - to:
+ uri: "kamelet:log-sink"
+ parameters:
+ showHeaders: true
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafkarouter/topic-name-matches-filter-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/topic-name-matches-filter-action-route.citrus.it.yaml
new file mode 100644
index 000000000..e7a34f111
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/topic-name-matches-filter-action-route.citrus.it.yaml
@@ -0,0 +1,30 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: topic-name-matches-filter-action-route-test
+actions:
+ - camel:
+ jbang:
+ run:
+ waitForRunningState: false
+ integration:
+ file: "kafkarouter/topic-name-matches-filter-action-route.yaml"
+ - camel:
+ jbang:
+ verify:
+ integration: "topic-name-matches-filter-action-route"
+ logMessage: "topic-filter-test-data"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafkarouter/topic-name-matches-filter-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/topic-name-matches-filter-action-route.yaml
new file mode 100644
index 000000000..2049740a0
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/kafkarouter/topic-name-matches-filter-action-route.yaml
@@ -0,0 +1,35 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "topic-filter-test-data"
+ - setHeader:
+ name: CamelKafkaTopic
+ constant: "orders-topic"
+ - to:
+ uri: "kamelet:topic-name-matches-filter-action"
+ parameters:
+ regex: "orders.*"
+ - to:
+ uri: "kamelet:log-sink"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/setbody/set-body-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/setbody/set-body-action-route.citrus.it.yaml
new file mode 100644
index 000000000..1098bab2a
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/setbody/set-body-action-route.citrus.it.yaml
@@ -0,0 +1,46 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: set-body-action-route-test
+variables:
+ - name: "set.body.value"
+ value: "Replaced body content"
+actions:
+ - camel:
+ jbang:
+ run:
+ integration:
+ file: "setbody/set-body-action-route.yaml"
+ systemProperties:
+ properties:
+ - name: "set.body.value"
+ value: "${set.body.value}"
+ - name: "http.sink.url"
+ value: "http://localhost:${http.server.port}";
+ - http:
+ server: "httpServer"
+ receiveRequest:
+ POST:
+ path: "/result"
+ body:
+ data: "${set.body.value}"
+ - http:
+ server: "httpServer"
+ sendResponse:
+ response:
+ status: 200
+ reasonPhrase: "OK"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/setbody/set-body-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/setbody/set-body-action-route.yaml
new file mode 100644
index 000000000..ff7ceb18c
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/setbody/set-body-action-route.yaml
@@ -0,0 +1,34 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "original-body"
+ - to:
+ uri: "kamelet:set-body-action"
+ parameters:
+ value: "{{set.body.value}}"
+ - to:
+ uri: "kamelet:http-sink"
+ parameters:
+ url: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/throttle/throttle-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/throttle/throttle-action-route.citrus.it.yaml
new file mode 100644
index 000000000..932c254f4
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/throttle/throttle-action-route.citrus.it.yaml
@@ -0,0 +1,46 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: throttle-action-route-test
+variables:
+ - name: "test.message"
+ value: "throttled-message-test"
+actions:
+ - camel:
+ jbang:
+ run:
+ integration:
+ file: "throttle/throttle-action-route.yaml"
+ systemProperties:
+ properties:
+ - name: "test.message"
+ value: "${test.message}"
+ - name: "http.sink.url"
+ value: "http://localhost:${http.server.port}";
+ - http:
+ server: "httpServer"
+ receiveRequest:
+ POST:
+ path: "/result"
+ body:
+ data: "${test.message}"
+ - http:
+ server: "httpServer"
+ sendResponse:
+ response:
+ status: 200
+ reasonPhrase: "OK"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/throttle/throttle-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/throttle/throttle-action-route.yaml
new file mode 100644
index 000000000..bb4eb2c85
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/throttle/throttle-action-route.yaml
@@ -0,0 +1,34 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: "{{test.message}}"
+ - to:
+ uri: "kamelet:throttle-action"
+ parameters:
+ messages: 5
+ - to:
+ uri: "kamelet:http-sink"
+ parameters:
+ url: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/xj/xj-identity-action-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/xj/xj-identity-action-route.citrus.it.yaml
new file mode 100644
index 000000000..6a5322254
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/xj/xj-identity-action-route.citrus.it.yaml
@@ -0,0 +1,44 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+name: xj-identity-action-route-test
+actions:
+ - camel:
+ jbang:
+ run:
+ integration:
+ file: "xj/xj-identity-action-route.yaml"
+ systemProperties:
+ properties:
+ - name: "http.sink.url"
+ value: "http://localhost:${http.server.port}";
+ - http:
+ server: "httpServer"
+ receiveRequest:
+ POST:
+ path: "/result"
+ - http:
+ server: "httpServer"
+ sendResponse:
+ response:
+ status: 200
+ reasonPhrase: "OK"
+ - camel:
+ jbang:
+ verify:
+ integration: "xj-identity-action-route"
+ logMessage: "name"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/xj/xj-identity-action-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/xj/xj-identity-action-route.yaml
new file mode 100644
index 000000000..ca0ccf4be
--- /dev/null
+++
b/tests/camel-kamelets-itest/src/test/resources/xj/xj-identity-action-route.yaml
@@ -0,0 +1,38 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+- route:
+ from:
+ uri: "timer:tick"
+ parameters:
+ period: "10000"
+ repeatCount: 1
+ steps:
+ - setBody:
+ constant: '{"name":"test","value":"hello"}'
+ - to:
+ uri: "kamelet:xj-identity-action"
+ parameters:
+ direction: "JSON2XML"
+ - to:
+ uri: "kamelet:log-sink"
+ parameters:
+ showHeaders: true
+ - to:
+ uri: "kamelet:http-sink"
+ parameters:
+ url: "{{http.sink.url}}/result"
