(camel) 02/05: camel-jbang - Prototype for transform message command.

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch jp
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 0f74ef490e413a2ecadad8f20516f861ccd2c9ce
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Nov 25 14:37:22 2023 +0100

    camel-jbang - Prototype for transform message command.
---
 .../java/org/apache/camel/cli/connector/LocalCliConnector.java     | 2 +-
 .../dsl/jbang/core/commands/action/TransformMessageAction.java     | 7 +++++--
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/dsl/camel-cli-connector/src/main/java/org/apache/camel/cli/connector/LocalCliConnector.java
 
b/dsl/camel-cli-connector/src/main/java/org/apache/camel/cli/connector/LocalCliConnector.java
index 110adf2b29c..f992d5a0235 100644
--- 
a/dsl/camel-cli-connector/src/main/java/org/apache/camel/cli/connector/LocalCliConnector.java
+++ 
b/dsl/camel-cli-connector/src/main/java/org/apache/camel/cli/connector/LocalCliConnector.java
@@ -503,7 +503,7 @@ public class LocalCliConnector extends ServiceSupport 
implements CliConnector, C
                     if (body.startsWith("file:")) {
                         File file = new File(body.substring(5));
                         is = new FileInputStream(file);
-                        b = is;
+                        b = IOHelper.loadText(is);
                     }
                     if (headers != null) {
                         map = new LinkedHashMap<>();
diff --git 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/TransformMessageAction.java
 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/TransformMessageAction.java
index aa8d2e34637..d51c3247160 100644
--- 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/TransformMessageAction.java
+++ 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/TransformMessageAction.java
@@ -38,7 +38,7 @@ import picocli.CommandLine;
 @CommandLine.Command(name = "message",
                      description = "Transform message from one format to 
another via an existing running Camel integration",
                      sortOptions = false)
-public class TransformMessageAction extends ActionBaseCommand {
+public class TransformMessageAction extends ActionWatchCommand {
 
     @CommandLine.Parameters(description = "Name or pid of running Camel 
integration", arity = "0..1")
     String name = "*";
@@ -104,7 +104,7 @@ public class TransformMessageAction extends 
ActionBaseCommand {
     }
 
     @Override
-    public Integer doCall() throws Exception {
+    protected Integer doWatchCall() throws Exception {
         List<Long> pids = findPids(name);
         if (pids.isEmpty()) {
             return 0;
@@ -183,6 +183,9 @@ public class TransformMessageAction extends 
ActionBaseCommand {
                     cause = null;
                 }
                 if (output == null) {
+                    if (watch) {
+                        clearScreen();
+                    }
                     tableHelper = new MessageTableHelper();
                     tableHelper.setPretty(pretty);
                     tableHelper.setLoggingColor(loggingColor);