This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new ca77c1a11c8 CAMEL-20217: camel-jbang - You can now camel init a pipe file. ca77c1a11c8 is described below commit ca77c1a11c8e1a85d25dfef61bac8dfe8e3d055b Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Mon May 20 10:47:21 2024 +0200 CAMEL-20217: camel-jbang - You can now camel init a pipe file. --- .../org/apache/camel/dsl/jbang/core/commands/Init.java | 6 ++++++ .../apache/camel/dsl/jbang/core/commands/bind/Bind.java | 3 --- .../src/main/resources/templates/init-pipe.yaml.tmpl | 17 +++++++++++++++++ 3 files changed, 23 insertions(+), 3 deletions(-) diff --git a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java index 42ab2a55335..2c03f571d75 100644 --- a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java +++ b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java @@ -69,6 +69,10 @@ public class Init extends CamelCommand { description = "When creating a yaml file should it be created as a Camel K Integration CRD") private boolean integration; + @Option(names = { "--pipe" }, + description = "When creating a yaml file should it be created as a Camel K Pipe CRD") + private boolean pipe; + public Init(CamelJBangMain main) { super(main); } @@ -96,6 +100,8 @@ public class Init extends CamelCommand { String ext = FileUtil.onlyExt(file, false); if ("yaml".equals(ext) && integration) { ext = "integration.yaml"; + } else if ("yaml".equals(ext) && pipe) { + ext = "init-pipe.yaml"; } if (fromKamelet != null && !"kamelet.yaml".equals(ext)) { diff --git a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java index e1236d39574..c81351c9fa9 100644 --- a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java +++ b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java @@ -245,9 +245,6 @@ public class Bind extends CamelCommand { /** * Extracts properties from given property arguments. Filter properties by given prefix. This way each component in * pipe (source, sink, errorHandler, step[1-n]) can have its individual properties. - * - * @param keyPrefix - * @return */ private Map<String, Object> getProperties(String keyPrefix) { Map<String, Object> props = new HashMap<>(); diff --git a/dsl/camel-jbang/camel-jbang-core/src/main/resources/templates/init-pipe.yaml.tmpl b/dsl/camel-jbang/camel-jbang-core/src/main/resources/templates/init-pipe.yaml.tmpl new file mode 100644 index 00000000000..9e9beffcc07 --- /dev/null +++ b/dsl/camel-jbang/camel-jbang-core/src/main/resources/templates/init-pipe.yaml.tmpl @@ -0,0 +1,17 @@ +apiVersion: camel.apache.org/v1 +kind: Pipe +metadata: + name: {{ .Name }} +spec: + source: + ref: + kind: Kamelet + apiVersion: camel.apache.org/v1 + name: timer-source + properties: + message: Hello World + sink: + ref: + kind: Kamelet + apiVersion: camel.apache.org/v1 + name: log-sink \ No newline at end of file