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 09a0f0745 Fix #2873: migrate the transformation itests from Pipe to
Camel routes (#3040)
09a0f0745 is described below
commit 09a0f0745c964e3e39898d5867b1ef7fa38b2c40
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu Sep 17 10:18:14 2026 +0200
Fix #2873: migrate the transformation itests from Pipe to Camel routes
(#3040)
First tranche of the Pipe to route migration. The transformation directory
is
the largest uniform group, seven tests that all share the same shape: a
timer-source, one action Kamelet in the middle and an HTTP sink.
Each Pipe becomes a plain YAML DSL route, with the source ref turning into
the
route from, the step refs into to steps, and the sink into the terminal to.
The
files follow the naming already used by the route based tests in this
module,
so <name>-pipe.yaml becomes <name>-route.yaml, the Citrus file is renamed to
match and the test name moves from <name>-pipe-test to <name>-route-test.
Nothing about what is exercised changes: the same Kamelet, the same
properties
and the same assertions.
Verified with a clean run, which also confirms no stale Pipe copies are left
behind in target:
TOTAL: 7 PASSED: 7 (100.0%)
Thirty-eight of the forty Pipe based tests can migrate this way. The two
remaining, aws/s3/aws-s3-to-knative-broker.yaml and
aws/s3/knative-to-log.yaml,
bind a Knative Broker rather than a Kamelet or a plain URI and exercise that
binding specifically, so they are deliberately left as Pipes.
Co-authored-by: Claude Opus 5 <[email protected]>
---
.../transformation/data-type-action-pipe.yaml | 50 ----------------------
....yaml => data-type-action-route.citrus.it.yaml} | 4 +-
...ction-pipe.yaml => data-type-action-route.yaml} | 42 ++++++++----------
...yaml => drop-field-action-route.citrus.it.yaml} | 4 +-
...tion-pipe.yaml => drop-field-action-route.yaml} | 37 ++++++----------
...l => extract-field-action-route.citrus.it.yaml} | 4 +-
...n-pipe.yaml => extract-field-action-route.yaml} | 37 ++++++----------
...aml => hoist-field-action-route.citrus.it.yaml} | 4 +-
...ion-pipe.yaml => hoist-field-action-route.yaml} | 37 ++++++----------
.../transformation/insert-field-action-pipe.yaml | 41 ------------------
...ml => insert-field-action-route.citrus.it.yaml} | 4 +-
...on-pipe.yaml => insert-field-action-route.yaml} | 38 +++++++---------
.../transformation/mask-field-action-pipe.yaml | 41 ------------------
...yaml => mask-field-action-route.citrus.it.yaml} | 4 +-
...tion-pipe.yaml => mask-field-action-route.yaml} | 38 +++++++---------
...l => replace-field-action-route.citrus.it.yaml} | 4 +-
...n-pipe.yaml => replace-field-action-route.yaml} | 37 ++++++----------
17 files changed, 119 insertions(+), 307 deletions(-)
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-pipe.yaml
deleted file mode 100644
index cbfd8a00b..000000000
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-pipe.yaml
+++ /dev/null
@@ -1,50 +0,0 @@
-# ---------------------------------------------------------------------------
-# 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.
-# ---------------------------------------------------------------------------
-
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: data-type-action-pipe
-spec:
- integration:
- dependencies:
- - "camel:cloudevents"
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: data-type-action
- properties:
- scheme: "http"
- format: "application-cloudevents"
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: log-action
- properties:
- showHeaders: true
- sink:
- uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-route.citrus.it.yaml
index b1697ce45..1e03feaf8 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: data-type-action-pipe-test
+name: data-type-action-route-test
variables:
- name: "uuid"
value: "citrus:randomUUID()"
@@ -30,7 +30,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/data-type-action-pipe.yaml"
+ file: "transformation/data-type-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-route.yaml
similarity index 65%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-pipe.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-route.yaml
index 0a2ee004e..f50b59caa 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/data-type-action-route.yaml
@@ -15,26 +15,22 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: hoist-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: hoist-field-action
- properties:
- field: "{{hoist.field}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:data-type-action"
+ parameters:
+ scheme: "http"
+ format: "application-cloudevents"
+ - to:
+ uri: "kamelet:log-action"
+ parameters:
+ showHeaders: true
+ - to:
+ uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-route.citrus.it.yaml
index 80049b9ef..e408ac9b3 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: drop-field-action-pipe-test
+name: drop-field-action-route-test
variables:
- name: "field.name"
value: "subject"
@@ -32,7 +32,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/drop-field-action-pipe.yaml"
+ file: "transformation/drop-field-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-route.yaml
similarity index 65%
copy from
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
copy to
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-route.yaml
index 4e06f342c..4c9cea865 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-route.yaml
@@ -15,26 +15,17 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: drop-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: drop-field-action
- properties:
- field: "{{field.name}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:drop-field-action"
+ parameters:
+ field: "{{field.name}}"
+ - to:
+ uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-route.citrus.it.yaml
index 04237377a..d5db614dd 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: extract-field-action-pipe-test
+name: extract-field-action-route-test
variables:
- name: "field.name"
value: "subject"
@@ -32,7 +32,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/extract-field-action-pipe.yaml"
+ file: "transformation/extract-field-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-route.yaml
similarity index 65%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-pipe.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-route.yaml
index 70dcabfda..326306410 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-route.yaml
@@ -15,26 +15,17 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: replace-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: replace-field-action
- properties:
- renames: "{{renames}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:extract-field-action"
+ parameters:
+ field: "{{field.name}}"
+ - to:
+ uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-route.citrus.it.yaml
index 72b85deca..de338f96e 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: hoist-field-action-pipe-test
+name: hoist-field-action-route-test
variables:
- name: "id"
value: "citrus:randomUUID()"
@@ -32,7 +32,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/hoist-field-action-pipe.yaml"
+ file: "transformation/hoist-field-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-route.yaml
similarity index 65%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-pipe.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-route.yaml
index 947867457..48930a365 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/extract-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/hoist-field-action-route.yaml
@@ -15,26 +15,17 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: extract-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: extract-field-action
- properties:
- field: "{{field.name}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:hoist-field-action"
+ parameters:
+ field: "{{hoist.field}}"
+ - to:
+ uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-pipe.yaml
deleted file mode 100644
index f4149fe82..000000000
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-pipe.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# ---------------------------------------------------------------------------
-# 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.
-# ---------------------------------------------------------------------------
-
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: insert-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: insert-field-action
- properties:
- field: "{{field.name}}"
- value: "{{field.value}}"
- sink:
- uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-route.citrus.it.yaml
index 7ac21be9b..2d7c4169e 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: insert-field-action-pipe-test
+name: insert-field-action-route-test
variables:
- name: "id"
value: "citrus:randomUUID()"
@@ -34,7 +34,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/insert-field-action-pipe.yaml"
+ file: "transformation/insert-field-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-route.yaml
similarity index 65%
copy from
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
copy to
tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-route.yaml
index 4e06f342c..87597a24c 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/insert-field-action-route.yaml
@@ -15,26 +15,18 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: drop-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: drop-field-action
- properties:
- field: "{{field.name}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:insert-field-action"
+ parameters:
+ field: "{{field.name}}"
+ value: "{{field.value}}"
+ - to:
+ uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-pipe.yaml
deleted file mode 100644
index 29002d893..000000000
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-pipe.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# ---------------------------------------------------------------------------
-# 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.
-# ---------------------------------------------------------------------------
-
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: mask-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: mask-field-action
- properties:
- fields: "{{mask.fields}}"
- replacement: "{{mask.replacement}}"
- sink:
- uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-route.citrus.it.yaml
index 608d4b7e5..a4a7a2d4b 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: mask-field-action-pipe-test
+name: mask-field-action-route-test
variables:
- name: "id"
value: "citrus:randomUUID()"
@@ -34,7 +34,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/mask-field-action-pipe.yaml"
+ file: "transformation/mask-field-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-route.yaml
similarity index 65%
copy from
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
copy to
tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-route.yaml
index 4e06f342c..ce375edd0 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/mask-field-action-route.yaml
@@ -15,26 +15,18 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: drop-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: drop-field-action
- properties:
- field: "{{field.name}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:mask-field-action"
+ parameters:
+ fields: "{{mask.fields}}"
+ replacement: "{{mask.replacement}}"
+ - to:
+ uri: "{{http.sink.url}}/result"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-route.citrus.it.yaml
similarity index 95%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-pipe.citrus.it.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-route.citrus.it.yaml
index c03484cea..b2d892716 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-route.citrus.it.yaml
@@ -15,7 +15,7 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-name: replace-field-action-pipe-test
+name: replace-field-action-route-test
variables:
- name: "field.value"
value: "Camel rocks!"
@@ -30,7 +30,7 @@ actions:
run:
waitForRunningState: false
integration:
- file: "transformation/replace-field-action-pipe.yaml"
+ file: "transformation/replace-field-action-route.yaml"
systemProperties:
properties:
- name: "http.sink.url"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-route.yaml
similarity index 65%
rename from
tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
rename to
tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-route.yaml
index 4e06f342c..dd450c000 100644
---
a/tests/camel-kamelets-itest/src/test/resources/transformation/drop-field-action-pipe.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/transformation/replace-field-action-route.yaml
@@ -15,26 +15,17 @@
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
- name: drop-field-action-pipe
-spec:
- source:
- ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: timer-source
- properties:
- period: 10000
- contentType: application/json
- message: "{{input}}"
- steps:
- - ref:
- kind: Kamelet
- apiVersion: camel.apache.org/v1
- name: drop-field-action
- properties:
- field: "{{field.name}}"
- sink:
- uri: "{{http.sink.url}}/result"
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 10000
+ contentType: "application/json"
+ message: "{{input}}"
+ steps:
+ - to:
+ uri: "kamelet:replace-field-action"
+ parameters:
+ renames: "{{renames}}"
+ - to:
+ uri: "{{http.sink.url}}/result"
