summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/main/java/com/keuin/crosslink/plugin/bungee/BungeeAccessor.java3
-rw-r--r--src/test/java/com/keuin/crosslink/testable/FakeRouter.java5
2 files changed, 7 insertions, 1 deletions
diff --git a/src/main/java/com/keuin/crosslink/plugin/bungee/BungeeAccessor.java b/src/main/java/com/keuin/crosslink/plugin/bungee/BungeeAccessor.java
index 957927e..525f16b 100644
--- a/src/main/java/com/keuin/crosslink/plugin/bungee/BungeeAccessor.java
+++ b/src/main/java/com/keuin/crosslink/plugin/bungee/BungeeAccessor.java
@@ -41,7 +41,8 @@ public class BungeeAccessor implements ICoreAccessor {
var checker = new BungeeServerStatusChecker(
plugin.getProxy().getServers().values(),
plugin,
- GlobalConfigManager.getInstance().getConfig().pingTimeoutMillis()
+// GlobalConfigManager.getInstance().getConfig().pingTimeoutMillis()
+ 2000
);
checker.ping((infoMap) -> callback.accept(infoMap.entrySet().stream().map(
(ent) -> new ServerInfo(ent.getKey().getName(), ent.getValue())
diff --git a/src/test/java/com/keuin/crosslink/testable/FakeRouter.java b/src/test/java/com/keuin/crosslink/testable/FakeRouter.java
index 0512b3e..f5ee0e3 100644
--- a/src/test/java/com/keuin/crosslink/testable/FakeRouter.java
+++ b/src/test/java/com/keuin/crosslink/testable/FakeRouter.java
@@ -47,6 +47,11 @@ public class FakeRouter implements IRouter {
this.rules = newChain;
}
+ @Override
+ public void clearEndpoints() {
+ endpoints.clear();
+ }
+
public List<IMessage> getMessages() {
return messages;
}