diff --git a/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java b/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java index 3dfe7e15eb0a77cc547619d325314f1810fa0163..f9d41fcd95e3c1052b9ffc906ecb69424a3cc0bf 100644 --- a/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java +++ b/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java @@ -23,6 +23,8 @@ import com.corundumstudio.socketio.SocketIOServer; import com.corundumstudio.socketio.listener.ConnectListener; import com.corundumstudio.socketio.listener.DataListener; import com.corundumstudio.socketio.listener.DisconnectListener; +import com.corundumstudio.socketio.parser.Packet; +import com.corundumstudio.socketio.parser.PacketType; import de.thm.arsnova.entities.User; import de.thm.arsnova.events.ARSnovaEvent; @@ -70,6 +72,13 @@ public class ARSnovaSocketIOServer { for (SocketIOClient c : server.getAllClients()) { c.disconnect(); } + + int clientCount = 0; + for (SocketIOClient c : server.getAllClients()) { + c.send(new Packet(PacketType.DISCONNECT)); + clientCount++; + } + LOGGER.info("Pending websockets at @PreDestroy: {}", clientCount); server.stop(); }