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 0a8fc9314cc CAMEL-20367: Adds Camel watch and Route DSL transformation
tests (#17756)
0a8fc9314cc is described below
commit 0a8fc9314ccd6571e8a5686f38d381e728ab1375
Author: Jakub Vrubel <[email protected]>
AuthorDate: Tue Apr 15 11:39:33 2025 +0200
CAMEL-20367: Adds Camel watch and Route DSL transformation tests (#17756)
---
.../org/apache/camel/dsl/jbang/it/CmdStartStopITCase.java | 15 +++++++++++++++
.../apache/camel/dsl/jbang/it/TransformMessageITCase.java | 8 ++++++++
2 files changed, 23 insertions(+)
diff --git
a/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/CmdStartStopITCase.java
b/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/CmdStartStopITCase.java
index f0bb62c2fc8..ca65dcb92e1 100644
---
a/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/CmdStartStopITCase.java
+++
b/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/CmdStartStopITCase.java
@@ -19,6 +19,7 @@ package org.apache.camel.dsl.jbang.it;
import java.io.IOException;
import org.apache.camel.dsl.jbang.it.support.JBangTestSupport;
+import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
public class CmdStartStopITCase extends JBangTestSupport {
@@ -93,4 +94,18 @@ public class CmdStartStopITCase extends JBangTestSupport {
checkCommandOutputsPattern("get route",
"route1\\s+timer:\\/\\/(yaml|java)\\?period=1000\\s+Started.*\\n.*route2\\s+timer:\\/\\/(yaml|java)\\?period=1000\\s+Started");
}
+
+ @Test
+ public void testCamelWatch() throws IOException {
+ copyResourceInDataFolder(TestResources.ROUTE2);
+ String PID = executeBackground(String.format("run %s/route2.yaml",
mountPoint()));
+ newFileInDataFolder("watch-sleep", "nohup camel ps --watch&\n" +
+ "sleep 5\n" +
+ "echo \"q\"\n");
+ execInContainer(String.format("chmod +x %s/watch-sleep",
mountPoint()));
+ Assertions.assertThat(
+ execInContainer(String.format("%s/watch-sleep", mountPoint())))
+ .as("watch command should output PID" + PID)
+ .contains(PID);
+ }
}
diff --git
a/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/TransformMessageITCase.java
b/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/TransformMessageITCase.java
index 0752ec76050..2ccfeb0688a 100644
---
a/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/TransformMessageITCase.java
+++
b/dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/TransformMessageITCase.java
@@ -53,6 +53,14 @@ public class TransformMessageITCase extends JBangTestSupport
{
checkOutputFile("[[Jack Dalton, 115, mad at Averell]");
}
+ @Test
+ public void testTransformRouteDSL() throws IOException {
+ copyResourceInDataFolder(TestResources.ROUTE2);
+ execute(String.format("transform route --format=xml %s/route2.yaml
--output=%s/route2.xml", mountPoint(),
+ mountPoint()));
+ assertFileInDataFolderContains("route2.xml", "<constant>Hello Camel
from custom integration</constant>");
+ }
+
private void runTransformation(String command) {
checkCommandOutputs(command, "Camel Main: transform (state: Running)");
}