chore: start with a simple stream example

data-probe/pom.xml

@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>f1-data</artifactId>
+        <groupId>com.mrmorais</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>f1-data-dataprobe</artifactId>
+
+    <properties>
+        <maven.compiler.source>18</maven.compiler.source>
+        <maven.compiler.target>18</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-core</artifactId>
+            <version>3.18.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-stream</artifactId>
+            <version>3.18.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-log4j12</artifactId>
+            <version>1.7.36</version>
+        </dependency>
+    </dependencies>
+</project>

data-probe/src/main/java/com/mrmorais/f122/StreamExample.java

@@ -0,0 +1,40 @@
+package com.mrmorais.f122;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.CountDownLatch;
+
+public class StreamExample {
+  private final static Logger log = LoggerFactory.getLogger(StreamExample.class);
+
+  public static void main(String[] args) throws Exception {
+    CamelContext camelContext = new DefaultCamelContext();
+
+    camelContext.addRoutes(new StreamInOutBuilder());
+
+    CountDownLatch latch = new CountDownLatch(1);
+
+    Runtime.getRuntime().addShutdownHook(new Thread(() -> {
+      try {
+        camelContext.close();
+      } catch (Exception e) {
+        log.error("Error closing CamelContext", e);
+      } finally {
+        latch.countDown();
+      }
+    }));
+
+    try {
+      camelContext.start();
+      latch.await();
+    } catch (Throwable e) {
+      log.error("Error starting CamelContext", e);
+      System.exit(1);
+    }
+
+    System.exit(0);
+  }
+}

data-probe/src/main/java/com/mrmorais/f122/StreamInOutBuilder.java

@@ -0,0 +1,11 @@
+package com.mrmorais.f122;
+
+import org.apache.camel.builder.RouteBuilder;
+
+public class StreamInOutBuilder extends RouteBuilder {
+
+  @Override
+  public void configure() {
+    from("stream:in").to("stream:out");
+  }
+}

pom.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.mrmorais</groupId>
+    <artifactId>f1-data</artifactId>
+    <packaging>pom</packaging>
+    <version>1.0-SNAPSHOT</version>
+    <modules>
+        <module>telemetry</module>
+        <module>data-probe</module>
+    </modules>
+
+    <properties>
+        <maven.compiler.source>18</maven.compiler.source>
+        <maven.compiler.target>18</maven.compiler.target>
+    </properties>
+</project>

telemetry/pom.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>f1-data</artifactId>
+        <groupId>com.mrmorais</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>f1-data-telemetry</artifactId>
+
+    <properties>
+        <maven.compiler.source>18</maven.compiler.source>
+        <maven.compiler.target>18</maven.compiler.target>
+    </properties>
+
+</project>