diff options
| -rw-r--r-- | juick-server-web/src/main/java/com/juick/server/component/JuickServerComponent.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/juick-server-web/src/main/java/com/juick/server/component/JuickServerComponent.java b/juick-server-web/src/main/java/com/juick/server/component/JuickServerComponent.java index 71e81f2d..792f446f 100644 --- a/juick-server-web/src/main/java/com/juick/server/component/JuickServerComponent.java +++ b/juick-server-web/src/main/java/com/juick/server/component/JuickServerComponent.java @@ -59,7 +59,7 @@ public class JuickServerComponent extends TextWebSocketHandler { if (session != null && session.isOpen()) { logger.debug("Sending WebSocket ping"); session.sendMessage(new PingMessage()); - } else { + } else if (!closeFlag.get()) { applicationEventPublisher.publishEvent(new DisconnectedEvent(this)); } } |