Server side

NSteell · Dec 7, 2017 · 7b9ad51 · 7b9ad51
1 parent 59cde37
commit 7b9ad51
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/LavalinkServer/src/main/java/lavalink/server/io/SocketServer.java b/LavalinkServer/src/main/java/lavalink/server/io/SocketServer.java
@@ -108,6 +108,7 @@ public void onMessage(WebSocket webSocket, String s) {
 
         if (webSocket.isClosing()) {
             log.error("Ignoring closing websocket: " + webSocket.getRemoteSocketAddress().toString());
+            return;
         }
 
         switch (json.getString("op")) {
@@ -119,11 +120,6 @@ public void onMessage(WebSocket webSocket, String s) {
                 if (manager.getConnectionListener() == null) {
                     manager.setConnectionListener(new DebugConnectionListener(guildId));
                 }
-                if (manager.isConnected() || manager.isAttemptingToConnect()) {
-                    manager.closeAudioConnection();
-                    log.info("Closing the audio connection for guild {} so we can reconnect.", guildId);
-                }
-
                 manager.openAudioConnection(json.getString("channelId"));
                 break;
             case "voiceUpdate":