From 36136d0c0fe753bafa580534d7ade4cdf632e47f Mon Sep 17 00:00:00 2001 From: mohammed jasem alaajel Date: Sun, 17 Jul 2022 08:31:55 +0400 Subject: [PATCH] remove leftover debug from cluster testing and handle config correctly --- .../minecraft/redisbungee/RedisBungeeBungeePlugin.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java index 767a12a..d8034b3 100644 --- a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java +++ b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java @@ -32,6 +32,7 @@ import net.md_5.bungee.api.plugin.Plugin; import net.md_5.bungee.config.Configuration; import net.md_5.bungee.config.ConfigurationProvider; import net.md_5.bungee.config.YamlConfiguration; +import org.apache.commons.pool2.impl.GenericObjectPoolConfig; import redis.clients.jedis.*; import redis.clients.jedis.exceptions.JedisConnectionException; @@ -878,7 +879,9 @@ public class RedisBungeeBungeePlugin extends Plugin implements RedisBungeePlugin if (redisServer != null && !redisServer.isEmpty()) { if (yamlConfiguration.getBoolean("cluster-mode-enabled", false)) { - this.jedisSummoner = new ClusterJedisSummoner(new JedisCluster(new HostAndPort("192.168.0.150", 7000))); + GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig<>(); + poolConfig.setMaxTotal(yamlConfiguration.getInt("max-redis-connections", 8)); + this.jedisSummoner = new ClusterJedisSummoner(new JedisCluster(new HostAndPort(redisServer, redisPort), 5000, 5000, 60, serverId, redisPassword, poolConfig, useSSL)); this.redisBungeeMode = RedisBungeeMode.CLUSTER; getLogger().log(Level.INFO, "RedisBungee MODE: CLUSTER"); } else {