dev

src/main/java/com/its/op/websocket/ItsWebSocketSession.java

@@ -19,9 +19,8 @@ public class ItsWebSocketSession {
     }
 
     public void sendMessage(String command, TextMessage message) {
-
-        if (this.session != null && this.session.isOpen()) {
-            synchronized (this.session) {
+        synchronized (this.session) {
+            if (this.session != null && this.session.isOpen()) {
                 try {
                     this.session.sendMessage(message);
                 } catch (Exception e) {

src/main/java/com/its/op/websocket/ItsWebSocketSessionManager.java

@@ -61,14 +61,12 @@ public class ItsWebSocketSessionManager {
 
     public void sendBroadcastMessage(String command, TextMessage message) {
         this.sessionMap.forEach((key, session) -> {
-            //log.info("{}, {}, {}", command, message, key);
             session.sendMessage(command, message);
         });
     }
 
     public void sendBroadcastSigPhaseMessage(String command, TextMessage message) {
         this.sessionMap.forEach((key, session) -> {
-            //log.info("{}, {}, {}", command, message, key);
             if ("wall".equals(session.getGroupId())) {
                 session.sendMessage(command, message);
             }