(camel) 06/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.

[da...@apache.org]

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 39b50b2bf247a66cd89a993ce003b61bfa85733b
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat May 25 14:18:50 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.
---
 .../java/org/apache/camel/component/pulsar/PulsarEndpoint.java    | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
index 5a113317ca1..36633ac902d 100644
--- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
+++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
@@ -21,6 +21,7 @@ import org.apache.camel.Consumer;
 import org.apache.camel.Processor;
 import org.apache.camel.Producer;
 import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders;
+import org.apache.camel.spi.EndpointLocationAddress;
 import org.apache.camel.spi.Metadata;
 import org.apache.camel.spi.UriEndpoint;
 import org.apache.camel.spi.UriParam;
@@ -36,7 +37,7 @@ import org.apache.pulsar.client.api.PulsarClient;
 @UriEndpoint(scheme = "pulsar", firstVersion = "2.24.0", title = "Pulsar",
              syntax = "pulsar:persistence://tenant/namespace/topic", category = { Category.MESSAGING },
              headersClass = PulsarMessageHeaders.class)
-public class PulsarEndpoint extends DefaultEndpoint {
+public class PulsarEndpoint extends DefaultEndpoint implements EndpointLocationAddress {
 
     private PulsarClient pulsarClient;
 
@@ -60,6 +61,11 @@ public class PulsarEndpoint extends DefaultEndpoint {
         super(uri, component);
     }
 
+    @Override
+    public String getAddress() {
+        return pulsarConfiguration.getServiceUrl();
+    }
+
     @Override
     public Producer createProducer() {
         return new PulsarProducer(this);