(camel) 42/47: CAMEL-20798: Add RemoteAddress to endpoints so they can tell the url/hostname etc for the system it connects. This is needed for better monitoring, tracing and management. Add this information into camel-tracer as tags.

[davsclaus]

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

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

commit 40b0fbf3bd456159ef466323c62e5f07b48c0b0d
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue May 28 07:37:34 2024 +0200

    CAMEL-20798: Add RemoteAddress to endpoints so they can tell the 
url/hostname etc for the system it connects. This is needed for better 
monitoring, tracing and management. Add this information into camel-tracer as 
tags.
---
 .../camel/component/ignite/AbstractIgniteEndpoint.java  | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/AbstractIgniteEndpoint.java
 
b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/AbstractIgniteEndpoint.java
index 166508a4e5e..9e81eca9da7 100644
--- 
a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/AbstractIgniteEndpoint.java
+++ 
b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/AbstractIgniteEndpoint.java
@@ -17,6 +17,7 @@
 package org.apache.camel.component.ignite;
 
 import org.apache.camel.Component;
+import org.apache.camel.spi.EndpointServiceLocation;
 import org.apache.camel.spi.UriParam;
 import org.apache.camel.support.DefaultEndpoint;
 import org.apache.ignite.Ignite;
@@ -24,7 +25,7 @@ import org.apache.ignite.Ignite;
 /**
  * Base class for all Ignite endpoints.
  */
-public abstract class AbstractIgniteEndpoint extends DefaultEndpoint {
+public abstract class AbstractIgniteEndpoint extends DefaultEndpoint 
implements EndpointServiceLocation {
 
     @UriParam(defaultValue = "true")
     private boolean propagateIncomingBodyIfNoReturnValue = true;
@@ -36,6 +37,20 @@ public abstract class AbstractIgniteEndpoint extends 
DefaultEndpoint {
         super(endpointUri, component);
     }
 
+    @Override
+    public String getServiceUrl() {
+        var a = ignite().cluster().localNode().addresses();
+        if (!a.isEmpty()) {
+            return a.iterator().next();
+        }
+        return null;
+    }
+
+    @Override
+    public String getServiceProtocol() {
+        return "ignite";
+    }
+
     protected AbstractIgniteComponent igniteComponent() {
         return (AbstractIgniteComponent) getComponent();
     }