From 28bf4d8f684cce4af9ab582f6bc59946aa0734b8 Mon Sep 17 00:00:00 2001
From: asvitkine <alexei.svitkine@gmail.com>
Date: Mon, 23 Oct 2023 22:43:05 -0400
Subject: [PATCH] Attempt to fix lobby connection error.

---
 .../http/client/web/socket/GenericWebSocketClient.java       | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/websocket-client/src/main/java/org/triplea/http/client/web/socket/GenericWebSocketClient.java b/lib/websocket-client/src/main/java/org/triplea/http/client/web/socket/GenericWebSocketClient.java
index 61f0b2dbe3..3f065e8ceb 100644
--- a/lib/websocket-client/src/main/java/org/triplea/http/client/web/socket/GenericWebSocketClient.java
+++ b/lib/websocket-client/src/main/java/org/triplea/http/client/web/socket/GenericWebSocketClient.java
@@ -6,6 +6,7 @@
 import java.net.URI;
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
@@ -44,7 +45,8 @@ public class GenericWebSocketClient implements WebSocket, WebSocketConnectionLis
   private final Function<URI, WebSocketConnection> webSocketConnectionFactory;
 
   private WebSocketConnection webSocketConnection;
-  private final Set<MessageListener<? extends WebSocketMessage>> listeners = new HashSet<>();
+  private final Set<MessageListener<? extends WebSocketMessage>> listeners =
+      Collections.synchronizedSet(new HashSet<>());
 
   @Builder
   private static class MessageListener<T extends WebSocketMessage> {
@@ -147,6 +149,7 @@ public void connectionTerminated(final String reason) {
 
   @Override
   public void handleError(final Throwable exception) {
+    log.error("Web Socket error", exception);
     errorHandler.accept(exception.getMessage());
   }
 }