(camel) 38/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 19af36ad53bd30249951de621e798e6ad3c7c3e2
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon May 27 21:40:55 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.
---
 .../apache/camel/impl/console/ServiceDevConsole.java   | 18 +++++++-----------
 1 file changed, 7 insertions(+), 11 deletions(-)

diff --git 
a/core/camel-console/src/main/java/org/apache/camel/impl/console/ServiceDevConsole.java
 
b/core/camel-console/src/main/java/org/apache/camel/impl/console/ServiceDevConsole.java
index 0ea70a63362..c6fa0bdcd0e 100644
--- 
a/core/camel-console/src/main/java/org/apache/camel/impl/console/ServiceDevConsole.java
+++ 
b/core/camel-console/src/main/java/org/apache/camel/impl/console/ServiceDevConsole.java
@@ -79,12 +79,10 @@ public class ServiceDevConsole extends AbstractDevConsole {
                 String adr = raa.getServiceUrl();
                 String protocol = raa.getServiceProtocol();
                 if (adr != null) {
-                    var stat = findStats(stats, endpoint.getEndpointUri(), 
"in");
-                    // skip IN as already found via consumer (platform-http is 
only IN)
-                    boolean skip
-                            = "platform-http".equals(component) || 
stat.isPresent() && "in".equals(stat.get().getDirection());
+                    // (platform-http is only IN)
+                    boolean skip = "platform-http".equals(component);
                     if (!skip) {
-                        stat = findStats(stats, endpoint.getEndpointUri(), 
"out");
+                        var stat = findStats(stats, endpoint.getEndpointUri(), 
"out");
                         var uri = endpoint.toString();
                         printLine(sb, component, stat, "out", hosted, 
protocol, adr, uri);
                     }
@@ -174,16 +172,14 @@ public class ServiceDevConsole extends AbstractDevConsole 
{
                 String adr = raa.getServiceUrl();
                 String protocol = raa.getServiceProtocol();
                 if (adr != null) {
-                    var stat = findStats(stats, endpoint.getEndpointUri(), 
"in");
-                    // skip IN as already found via consumer (platform-http is 
only IN)
-                    boolean skip
-                            = "platform-http".equals(component) || 
stat.isPresent() && "in".equals(stat.get().getDirection());
+                    // (platform-http is only IN)
+                    boolean skip = "platform-http".equals(component);
                     if (!skip) {
-                        stat = findStats(stats, endpoint.getEndpointUri(), 
"out");
+                        var stat = findStats(stats, endpoint.getEndpointUri(), 
"out");
                         var uri = endpoint.toString();
                         JsonObject jo = new JsonObject();
                         jo.put("component", component);
-                        jo.put("direction", "in");
+                        jo.put("direction", "out");
                         jo.put("hosted", hosted);
                         jo.put("protocol", protocol);
                         jo.put("address", adr);