This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 bc655630be55 camel-vertx-websocket: Add connected peer id to dev
console output (#19609)
bc655630be55 is described below
commit bc655630be552a60554bd8f38d38a4576d2a5d0f
Author: James Netherton <[email protected]>
AuthorDate: Fri Oct 17 17:44:05 2025 +0100
camel-vertx-websocket: Add connected peer id to dev console output (#19609)
---
.../camel/component/vertx/websocket/VertxWebsocketDevConsole.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketDevConsole.java
b/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketDevConsole.java
index 693a397b861f..67667c8639ea 100644
---
a/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketDevConsole.java
+++
b/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketDevConsole.java
@@ -57,6 +57,7 @@ public class VertxWebsocketDevConsole extends
AbstractDevConsole {
List<VertxWebsocketPeer> connectedPeers =
entry.getValue().getConnectedPeers();
sb.append(String.format("\n Connected Peers (%d): ",
connectedPeers.size()));
for (VertxWebsocketPeer peer : connectedPeers) {
+ sb.append(String.format("\n ID: %s",
peer.getConnectionKey()));
sb.append(String.format("\n Path: %s",
peer.getPath()));
ServerWebSocket webSocket = peer.getWebSocket();
@@ -96,6 +97,7 @@ public class VertxWebsocketDevConsole extends
AbstractDevConsole {
JsonArray peers = new JsonArray();
for (VertxWebsocketPeer peer :
entry.getValue().getConnectedPeers()) {
JsonObject peerJson = new JsonObject();
+ peerJson.put("id", peer.getConnectionKey());
peerJson.put("path", peer.getPath());
ServerWebSocket webSocket = peer.getWebSocket();