From 6f85353776930529134516a6d319a1a8a96c2fea Mon Sep 17 00:00:00 2001 From: mvarvarigos Date: Thu, 2 Apr 2026 21:04:13 +0300 Subject: [PATCH 1/4] camel-observability initial commit --- .../camel-observability-spring/pom.xml | 112 ++++++++++++++++++ .../src/data/message1.xml | 6 + .../src/data/message2.xml | 6 + .../FirstCamelSpringBootApplication.java | 27 +++++ .../camel/observablity/SimpleProcessor.java | 42 +++++++ .../observablity/SimpleRouteBuilder.java | 33 ++++++ .../src/main/resources/application.yml | 20 ++++ .../camel-observability-standalone/pom.xml | 101 ++++++++++++++++ .../src/data/message1.xml | 6 + .../src/data/message2.xml | 6 + .../baeldung/camel/observability/MainApp.java | 15 +++ .../camel/observability/SimpleProcessor.java | 42 +++++++ .../observability/SimpleRouteBuilder.java | 27 +++++ .../src/main/resources/application.properties | 1 + messaging-modules/camel-observability/pom.xml | 20 ++++ messaging-modules/pom.xml | 1 + 16 files changed, 465 insertions(+) create mode 100644 messaging-modules/camel-observability/camel-observability-spring/pom.xml create mode 100644 messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml create mode 100644 messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml create mode 100644 messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java create mode 100644 messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java create mode 100644 messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java create mode 100644 messaging-modules/camel-observability/camel-observability-spring/src/main/resources/application.yml create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/pom.xml create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/MainApp.java create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java create mode 100644 messaging-modules/camel-observability/camel-observability-standalone/src/main/resources/application.properties create mode 100644 messaging-modules/camel-observability/pom.xml diff --git a/messaging-modules/camel-observability/camel-observability-spring/pom.xml b/messaging-modules/camel-observability/camel-observability-spring/pom.xml new file mode 100644 index 000000000000..71d2f6c1a813 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/pom.xml @@ -0,0 +1,112 @@ + + + 4.0.0 + + com.baeldung + camel-observability + 0.0.1-SNAPSHOT + + + camel-observability-spring + + + 17 + + + + + + + org.springframework.boot + spring-boot-starter-parent + 3.5.11 + import + pom + + + + + + + org.springframework.boot + spring-boot-starter + + + org.springframework.boot + spring-boot-starter-web + + + org.apache.camel.springboot + camel-spring-boot-starter + 4.18.0 + + + org.springframework.boot + spring-boot-starter-actuator + + + org.springframework.boot + spring-boot-actuator-autoconfigure + + + org.apache.camel.springboot + camel-observation-starter + 4.18.0 + + + + io.micrometer + micrometer-tracing + 1.5.0 + + + io.micrometer + micrometer-tracing-bridge-brave + 1.5.0 + + + io.zipkin.reporter2 + zipkin-reporter-brave + + + io.micrometer + micrometer-registry-prometheus + 1.5.0 + + + + io.micrometer + micrometer-core + 1.15.9 + + + + ch.qos.logback + logback-core + 1.5.32 + + + ch.qos.logback + logback-classic + 1.5.32 + + + + org.springframework.boot + spring-boot-starter-test + test + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml b/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml new file mode 100644 index 000000000000..f2158449f567 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml @@ -0,0 +1,6 @@ + + + James + Strachan + London + \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml b/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml new file mode 100644 index 000000000000..5caa1928fe17 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml @@ -0,0 +1,6 @@ + + + Hiram + Chirino + Tampa + \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java new file mode 100644 index 000000000000..30dd8bd4c1d2 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java @@ -0,0 +1,27 @@ +package com.baeldung.camel.observablity; + +import org.apache.camel.observation.starter.CamelObservation; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.annotation.Bean; + + +@CamelObservation +@SpringBootApplication +public class FirstCamelSpringBootApplication { + + public static void main(String[] args) { + SpringApplication.run(FirstCamelSpringBootApplication.class, args); + } + + @Bean + SimpleProcessor simpleProcessor() { + return new SimpleProcessor(); + } + + @Bean + SimpleRouteBuilder simpleRouteBuilder(SimpleProcessor simpleProcessor) { + return new SimpleRouteBuilder(simpleProcessor); + } + +} diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java new file mode 100644 index 000000000000..b5192d10fdfa --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java @@ -0,0 +1,42 @@ +package com.baeldung.camel.observablity; + +import org.apache.camel.Exchange; +import org.apache.camel.Processor; +import org.w3c.dom.Document; +import org.w3c.dom.Element; + +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.transform.OutputKeys; +import javax.xml.transform.Transformer; +import javax.xml.transform.TransformerFactory; +import javax.xml.transform.dom.DOMSource; +import javax.xml.transform.stream.StreamResult; +import java.io.ByteArrayInputStream; +import java.io.InputStream; +import java.io.StringWriter; +import java.nio.charset.StandardCharsets; +import java.time.LocalDateTime; + +public class SimpleProcessor implements Processor { + + private static final DocumentBuilderFactory factory = DocumentBuilderFactory.newDefaultInstance(); + + @Override + public void process(Exchange exchange) throws Exception { + String body = exchange.getMessage().getBody(String.class); + String processedAt = LocalDateTime.now().toString(); + InputStream stream = new ByteArrayInputStream(body.getBytes(StandardCharsets.UTF_8)); + Document document = factory.newDocumentBuilder().parse(stream); + Element root = document.getDocumentElement(); + Element newElemeent = document.createElement("processed"); + newElemeent.setTextContent(processedAt); + root.appendChild(newElemeent); + TransformerFactory transformerFactory = TransformerFactory.newInstance(); + Transformer transformer = transformerFactory.newTransformer(); + transformer.setOutputProperty(OutputKeys.INDENT, "yes"); + StringWriter stringWriter = new StringWriter(); + transformer.transform(new DOMSource(document), new StreamResult(stringWriter)); + String newBody = stringWriter.toString(); + exchange.getMessage().setBody(newBody); + } +} diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java new file mode 100644 index 000000000000..a365fee49cc3 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java @@ -0,0 +1,33 @@ +package com.baeldung.camel.observablity; + +import org.apache.camel.builder.RouteBuilder; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +public class SimpleRouteBuilder extends RouteBuilder { + + private final SimpleProcessor simpleProcessor; + + @Autowired + public SimpleRouteBuilder(SimpleProcessor simpleProcessor) { + this.simpleProcessor = simpleProcessor; + } + + public void configure() { + from("file://src/data?noop=true") + .process(simpleProcessor) + .choice() + .when(xpath("/person/city = 'London'")) + .log("UK message") + .to("file:target/messages/uk") + .log("UK message 2") + .to("file:target/messages/general-sink") + .otherwise() + .log("Other message") + .to("file:target/messages/others") + .log("Other message 2") + .to("file:target/messages/general-sink"); + + } + +} diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/resources/application.yml b/messaging-modules/camel-observability/camel-observability-spring/src/main/resources/application.yml new file mode 100644 index 000000000000..e75edaf7c770 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/resources/application.yml @@ -0,0 +1,20 @@ +spring: + application: + name: first-camel-spring-boot +camel: + main: + run-controller: true + opentelemetry2: + enabled: true + trace-processors: true + trace-headers-inclusion: true +management: + tracing: + sampling: + probability: 1.0 + endpoints: + web: + exposure: + include: health,metrics,prometheus + server: + port: 7654 \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-standalone/pom.xml b/messaging-modules/camel-observability/camel-observability-standalone/pom.xml new file mode 100644 index 000000000000..01900d2644bf --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/pom.xml @@ -0,0 +1,101 @@ + + + 4.0.0 + + com.baeldung + camel-observability + 0.0.1-SNAPSHOT + + + camel-observability-standalone + + + UTF-8 + UTF-8 + + + + + + + org.apache.camel + camel-bom + 4.17.0 + import + pom + + + + + + + + org.apache.camel + camel-core + + + org.apache.camel + camel-main + + + org.apache.camel + camel-observability-services + + + org.apache.camel + camel-opentelemetry2 + + + ch.qos.logback + logback-classic + 1.5.29 + compile + + + + + org.apache.camel + camel-test + 3.22.4 + test + + + + + install + + + + org.apache.maven.plugins + maven-compiler-plugin + 3.10.1 + + 11 + + + + org.apache.maven.plugins + maven-resources-plugin + 3.2.0 + + UTF-8 + + + + + + org.apache.camel + camel-maven-plugin + 3.18.4 + + true + com.baeldung.camel.observability.MainApp + + + + + + + \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml new file mode 100644 index 000000000000..f2158449f567 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml @@ -0,0 +1,6 @@ + + + James + Strachan + London + \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml new file mode 100644 index 000000000000..5caa1928fe17 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml @@ -0,0 +1,6 @@ + + + Hiram + Chirino + Tampa + \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/MainApp.java b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/MainApp.java new file mode 100644 index 000000000000..3ac5c949f6c0 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/MainApp.java @@ -0,0 +1,15 @@ +package com.baeldung.camel.observability; + +import org.apache.camel.main.Main; + +public class MainApp { + + public static void main(String... args) throws Exception { + Main main = new Main(); + main.configure().addRoutesBuilder(new SimpleRouteBuilder()); + main.bind("SimpleProcessor", new SimpleProcessor()); + main.run(args); + } + +} + diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java new file mode 100644 index 000000000000..5d927f7b1573 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java @@ -0,0 +1,42 @@ +package com.baeldung.camel.observability; + +import org.apache.camel.Exchange; +import org.apache.camel.Processor; +import org.w3c.dom.Document; +import org.w3c.dom.Element; + +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.transform.OutputKeys; +import javax.xml.transform.Transformer; +import javax.xml.transform.TransformerFactory; +import javax.xml.transform.dom.DOMSource; +import javax.xml.transform.stream.StreamResult; +import java.io.ByteArrayInputStream; +import java.io.InputStream; +import java.io.StringWriter; +import java.nio.charset.StandardCharsets; +import java.time.LocalDateTime; + +public class SimpleProcessor implements Processor { + + private static final DocumentBuilderFactory factory = DocumentBuilderFactory.newDefaultInstance(); + + @Override + public void process(Exchange exchange) throws Exception { + String body = exchange.getMessage().getBody(String.class); + String processedAt = LocalDateTime.now().toString(); + InputStream stream = new ByteArrayInputStream(body.getBytes(StandardCharsets.UTF_8)); + Document document = factory.newDocumentBuilder().parse(stream); + Element root = document.getDocumentElement(); + Element newElemeent = document.createElement("processed"); + newElemeent.setTextContent(processedAt); + root.appendChild(newElemeent); + TransformerFactory transformerFactory = TransformerFactory.newInstance(); + Transformer transformer = transformerFactory.newTransformer(); + transformer.setOutputProperty(OutputKeys.INDENT, "yes"); + StringWriter stringWriter = new StringWriter(); + transformer.transform(new DOMSource(document), new StreamResult(stringWriter)); + String newBody = stringWriter.toString(); + exchange.getMessage().setBody(newBody); + } +} diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java new file mode 100644 index 000000000000..30bb2b5ac2a2 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java @@ -0,0 +1,27 @@ +package com.baeldung.camel.observability; + +import org.apache.camel.BeanInject; +import org.apache.camel.builder.RouteBuilder; + +public class SimpleRouteBuilder extends RouteBuilder { + + @BeanInject("SimpleProcessor") + SimpleProcessor simpleProcessor; + + public void configure() { + from("file:src/data?noop=true") + .process(simpleProcessor) + .choice() + .when(xpath("/person/city = 'London'")) + .log("UK message") + .to("file:target/messages/uk") + .log("UK message 2") + .to("file:target/messages/general-sink") + .otherwise() + .log("Other message") + .to("file:target/messages/others") + .log("Other message 2") + .to("file:target/messages/general-sink"); + } + +} diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/main/resources/application.properties b/messaging-modules/camel-observability/camel-observability-standalone/src/main/resources/application.properties new file mode 100644 index 000000000000..90b9e6bd8c23 --- /dev/null +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/main/resources/application.properties @@ -0,0 +1 @@ +camel.opentelemetry2.enabled=true \ No newline at end of file diff --git a/messaging-modules/camel-observability/pom.xml b/messaging-modules/camel-observability/pom.xml new file mode 100644 index 000000000000..843fcb1961af --- /dev/null +++ b/messaging-modules/camel-observability/pom.xml @@ -0,0 +1,20 @@ + + + 4.0.0 + + com.baeldung + messaging-modules + 0.0.1-SNAPSHOT + + + camel-observability + + pom + + camel-observability-spring + camel-observability-standalone + + + \ No newline at end of file diff --git a/messaging-modules/pom.xml b/messaging-modules/pom.xml index e79af560b95f..1b3be36168bd 100644 --- a/messaging-modules/pom.xml +++ b/messaging-modules/pom.xml @@ -28,6 +28,7 @@ postgres-notify ibm-mq dapr + camel-observability From c7be0ef1e1a1fce9a95eae875d380ac791e086cc Mon Sep 17 00:00:00 2001 From: mvarvarigos Date: Sat, 18 Apr 2026 22:53:57 +0300 Subject: [PATCH 2/4] formatting --- .../camel-observability-spring/pom.xml | 4 ++-- .../src/data/message1.xml | 6 ++--- .../src/data/message2.xml | 6 ++--- .../FirstCamelSpringBootApplication.java | 22 +++++++++---------- .../observablity/SimpleRouteBuilder.java | 16 +++++++------- .../camel-observability-standalone/pom.xml | 4 ++-- .../src/data/message1.xml | 6 ++--- .../src/data/message2.xml | 6 ++--- .../observability/SimpleRouteBuilder.java | 16 +++++++------- messaging-modules/camel-observability/pom.xml | 4 ++-- 10 files changed, 45 insertions(+), 45 deletions(-) diff --git a/messaging-modules/camel-observability/camel-observability-spring/pom.xml b/messaging-modules/camel-observability/camel-observability-spring/pom.xml index 71d2f6c1a813..77aa1df09e6e 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/pom.xml +++ b/messaging-modules/camel-observability/camel-observability-spring/pom.xml @@ -1,6 +1,6 @@ - 4.0.0 diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml b/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml index f2158449f567..2b6d64c2daaa 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml +++ b/messaging-modules/camel-observability/camel-observability-spring/src/data/message1.xml @@ -1,6 +1,6 @@ - James - Strachan - London + James + Strachan + London \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml b/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml index 5caa1928fe17..dce1d94206d8 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml +++ b/messaging-modules/camel-observability/camel-observability-spring/src/data/message2.xml @@ -1,6 +1,6 @@ - Hiram - Chirino - Tampa + Hiram + Chirino + Tampa \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java index 30dd8bd4c1d2..b2267d3421a0 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java @@ -10,18 +10,18 @@ @SpringBootApplication public class FirstCamelSpringBootApplication { - public static void main(String[] args) { - SpringApplication.run(FirstCamelSpringBootApplication.class, args); - } + public static void main(String[] args) { + SpringApplication.run(FirstCamelSpringBootApplication.class, args); + } - @Bean - SimpleProcessor simpleProcessor() { - return new SimpleProcessor(); - } + @Bean + SimpleProcessor simpleProcessor() { + return new SimpleProcessor(); + } - @Bean - SimpleRouteBuilder simpleRouteBuilder(SimpleProcessor simpleProcessor) { - return new SimpleRouteBuilder(simpleProcessor); - } + @Bean + SimpleRouteBuilder simpleRouteBuilder(SimpleProcessor simpleProcessor) { + return new SimpleRouteBuilder(simpleProcessor); + } } diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java index a365fee49cc3..22fa3c9f8fc5 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java @@ -18,15 +18,15 @@ public void configure() { .process(simpleProcessor) .choice() .when(xpath("/person/city = 'London'")) - .log("UK message") - .to("file:target/messages/uk") - .log("UK message 2") - .to("file:target/messages/general-sink") + .log("UK message") + .to("file:target/messages/uk") + .log("UK message 2") + .to("file:target/messages/general-sink") .otherwise() - .log("Other message") - .to("file:target/messages/others") - .log("Other message 2") - .to("file:target/messages/general-sink"); + .log("Other message") + .to("file:target/messages/others") + .log("Other message 2") + .to("file:target/messages/general-sink"); } diff --git a/messaging-modules/camel-observability/camel-observability-standalone/pom.xml b/messaging-modules/camel-observability/camel-observability-standalone/pom.xml index 01900d2644bf..5a9d7aa9b593 100644 --- a/messaging-modules/camel-observability/camel-observability-standalone/pom.xml +++ b/messaging-modules/camel-observability/camel-observability-standalone/pom.xml @@ -1,6 +1,6 @@ - 4.0.0 diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml index f2158449f567..2b6d64c2daaa 100644 --- a/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message1.xml @@ -1,6 +1,6 @@ - James - Strachan - London + James + Strachan + London \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml index 5caa1928fe17..dce1d94206d8 100644 --- a/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/data/message2.xml @@ -1,6 +1,6 @@ - Hiram - Chirino - Tampa + Hiram + Chirino + Tampa \ No newline at end of file diff --git a/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java index 30bb2b5ac2a2..a476daf442c0 100644 --- a/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java +++ b/messaging-modules/camel-observability/camel-observability-standalone/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java @@ -13,15 +13,15 @@ public void configure() { .process(simpleProcessor) .choice() .when(xpath("/person/city = 'London'")) - .log("UK message") - .to("file:target/messages/uk") - .log("UK message 2") - .to("file:target/messages/general-sink") + .log("UK message") + .to("file:target/messages/uk") + .log("UK message 2") + .to("file:target/messages/general-sink") .otherwise() - .log("Other message") - .to("file:target/messages/others") - .log("Other message 2") - .to("file:target/messages/general-sink"); + .log("Other message") + .to("file:target/messages/others") + .log("Other message 2") + .to("file:target/messages/general-sink"); } } diff --git a/messaging-modules/camel-observability/pom.xml b/messaging-modules/camel-observability/pom.xml index 843fcb1961af..880b54d9705d 100644 --- a/messaging-modules/camel-observability/pom.xml +++ b/messaging-modules/camel-observability/pom.xml @@ -1,6 +1,6 @@ - 4.0.0 From 18bcb89ee647a43f6340d2ae321b0645268e23d7 Mon Sep 17 00:00:00 2001 From: mvarvarigos Date: Thu, 23 Apr 2026 16:01:29 +0300 Subject: [PATCH 3/4] Fixed a typo in package name. --- .../FirstCamelSpringBootApplication.java | 2 +- .../camel/{observablity => observability}/SimpleProcessor.java | 2 +- .../{observablity => observability}/SimpleRouteBuilder.java | 3 +-- 3 files changed, 3 insertions(+), 4 deletions(-) rename messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/{observablity => observability}/FirstCamelSpringBootApplication.java (94%) rename messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/{observablity => observability}/SimpleProcessor.java (97%) rename messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/{observablity => observability}/SimpleRouteBuilder.java (91%) diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/FirstCamelSpringBootApplication.java similarity index 94% rename from messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java rename to messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/FirstCamelSpringBootApplication.java index b2267d3421a0..13a1e799e918 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/FirstCamelSpringBootApplication.java +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/FirstCamelSpringBootApplication.java @@ -1,4 +1,4 @@ -package com.baeldung.camel.observablity; +package com.baeldung.camel.observability; import org.apache.camel.observation.starter.CamelObservation; import org.springframework.boot.SpringApplication; diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java similarity index 97% rename from messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java rename to messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java index b5192d10fdfa..5d927f7b1573 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleProcessor.java +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/SimpleProcessor.java @@ -1,4 +1,4 @@ -package com.baeldung.camel.observablity; +package com.baeldung.camel.observability; import org.apache.camel.Exchange; import org.apache.camel.Processor; diff --git a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java similarity index 91% rename from messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java rename to messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java index 22fa3c9f8fc5..c5f64eb53f25 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observablity/SimpleRouteBuilder.java +++ b/messaging-modules/camel-observability/camel-observability-spring/src/main/java/com/baeldung/camel/observability/SimpleRouteBuilder.java @@ -1,8 +1,7 @@ -package com.baeldung.camel.observablity; +package com.baeldung.camel.observability; import org.apache.camel.builder.RouteBuilder; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; public class SimpleRouteBuilder extends RouteBuilder { From 75b82ad2be35a5c96ed390254813b36cbdbeeb54 Mon Sep 17 00:00:00 2001 From: mvarvarigos Date: Thu, 23 Apr 2026 16:14:46 +0300 Subject: [PATCH 4/4] Removed unnecessary dependency micrometer-registry-prometheus --- .../camel-observability/camel-observability-spring/pom.xml | 5 ----- 1 file changed, 5 deletions(-) diff --git a/messaging-modules/camel-observability/camel-observability-spring/pom.xml b/messaging-modules/camel-observability/camel-observability-spring/pom.xml index 77aa1df09e6e..968793323d98 100644 --- a/messaging-modules/camel-observability/camel-observability-spring/pom.xml +++ b/messaging-modules/camel-observability/camel-observability-spring/pom.xml @@ -70,11 +70,6 @@ io.zipkin.reporter2 zipkin-reporter-brave - - io.micrometer - micrometer-registry-prometheus - 1.5.0 - io.micrometer