(camel) branch main updated: CAMEL-22127: camel-vertx-websocket - Fix ConcurrentModificationException. Thanks to Kumar Gaurav for reporting.

[davsclaus]

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 553e403ce0b CAMEL-22127: camel-vertx-websocket - Fix 
ConcurrentModificationException. Thanks to Kumar Gaurav for reporting.
553e403ce0b is described below

commit 553e403ce0b08ef9d75eea9303f9d02cd9a70304
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Jun 5 22:38:17 2025 +0200

    CAMEL-22127: camel-vertx-websocket - Fix ConcurrentModificationException. 
Thanks to Kumar Gaurav for reporting.
---
 .../apache/camel/component/vertx/websocket/VertxWebsocketHost.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
 
b/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
index c473e3325c8..91b465cc7b3 100644
--- 
a/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
+++ 
b/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
@@ -17,12 +17,11 @@
 package org.apache.camel.component.vertx.websocket;
 
 import java.net.URI;
-import java.util.ArrayList;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.ExecutionException;
 import java.util.regex.Pattern;
 
@@ -53,7 +52,7 @@ public class VertxWebsocketHost {
     private final VertxWebsocketHostConfiguration hostConfiguration;
     private final VertxWebsocketHostKey hostKey;
     private final Map<String, Route> routeRegistry = new HashMap<>();
-    private final List<VertxWebsocketPeer> connectedPeers = 
Collections.synchronizedList(new ArrayList<>());
+    private final List<VertxWebsocketPeer> connectedPeers = new 
CopyOnWriteArrayList<>(); // thread-safe
     private final CamelContext camelContext;
     private HttpServer server;
     private int port = VertxWebsocketConstants.DEFAULT_VERTX_SERVER_PORT;