Krakatoa-Earth
/
ProxySystem
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

implemented KraSocketClient

master
Alex 2021-12-27 15:03:51 +01:00
parent 44112e5e32
commit f143804662
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java
View File

@ -2,6 +2,7 @@ package net.krakatoa.proxy.listener;
import earth.krakatao.events.KraSocketClientEventInterface; import earth.krakatao.events.KraSocketClientEventInterface;
import earth.krakatao.protocol.KraSocketClientProtocolMessage; import earth.krakatao.protocol.KraSocketClientProtocolMessage;
import java.util.concurrent.TimeUnit;
import net.krakatoa.proxy.ProxySystem; import net.krakatoa.proxy.ProxySystem;
import net.md_5.bungee.api.ProxyServer; import net.md_5.bungee.api.ProxyServer;
import net.md_5.bungee.api.chat.TextComponent; import net.md_5.bungee.api.chat.TextComponent;
@ -68,5 +69,15 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
new TextComponent( new TextComponent(
"§cSocket §8» §c" + (remote ? "Connection! Closed by remote peer" : reason))); "§cSocket §8» §c" + (remote ? "Connection! Closed by remote peer" : reason)));
} }
if (code != 1) {
ProxyServer.getInstance().getScheduler().schedule(ProxySystem.getInstance(), () -> {
for (ProxiedPlayer proxiedPlayer : ProxyServer.getInstance().getPlayers()) {
proxiedPlayer.sendMessage(new TextComponent("§cSocket §8» §7Reconnecting..."));
}
ProxySystem.getInstance().getKraSocketClient().getSocketClient().Reconnect();
}, 3L, TimeUnit.SECONDS);
}
} }
} }