(camel) branch main updated: fix(components): Bring observability log event back

[pcongiusti]

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

pcongiusti 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 a60d962d7ef fix(components): Bring observability log event back
a60d962d7ef is described below

commit a60d962d7ef00ede348b82a19b38f1206e61579d
Author: Pasquale Congiusti <pasquale.congiu...@gmail.com>
AuthorDate: Wed Aug 27 10:59:56 2025 +0200

    fix(components): Bring observability log event back
    
    * Will work in conjunction with 
https://github.com/apache/camel-spring-boot/pull/1493
    
    Revert #17445
    Ref CAMEL-22349
---
 .../observation/MicrometerObservationSpanAdapter.java    | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-observation/src/main/java/org/apache/camel/observation/MicrometerObservationSpanAdapter.java
 
b/components/camel-observation/src/main/java/org/apache/camel/observation/MicrometerObservationSpanAdapter.java
index 84e93392b55..5cb87f3245b 100644
--- 
a/components/camel-observation/src/main/java/org/apache/camel/observation/MicrometerObservationSpanAdapter.java
+++ 
b/components/camel-observation/src/main/java/org/apache/camel/observation/MicrometerObservationSpanAdapter.java
@@ -108,12 +108,24 @@ public class MicrometerObservationSpanAdapter implements 
SpanAdapter {
     public void log(Map<String, String> fields) {
         String event = fields.get("event");
         if ("error".equalsIgnoreCase(event)) {
-            setError(true);
+            if (fields.containsKey("message")) {
+                observation.error(new RuntimeException(fields.get("message")));
+            } else {
+                setError(true);
+            }
         } else {
-            observation.event(() -> DEFAULT_EVENT_NAME);
+            observation.event(() -> getMessageNameFromFields(fields));
         }
     }
 
+    String getMessageNameFromFields(Map<String, ?> fields) {
+        Object eventValue = fields == null ? null : fields.get("message");
+        if (eventValue != null) {
+            return eventValue.toString();
+        }
+        return DEFAULT_EVENT_NAME;
+    }
+
     @Override
     public String traceId() {
         TracingContext tracingContext = getTracingContext();