Limework/RedisBungee
2
0
Fork 0
mirror of https://github.com/proxiodev/RedisBungee.git synced 2024-11-22 20:28:00 +00:00
Code Releases Activity

add log option, check connection for JedisPooled

Browse Source
This commit is contained in:
mohammed jasem alaajel 2022-07-26 17:55:16 +04:00
parent d77e909e7d
commit 2ae9b5d480
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/api/config/ConfigLoader.java
View File

@ -109,6 +109,7 @@ public interface ConfigLoader {
config.setMaxTotal(node.getNode("compatibility-max-connections").getInt(3)); config.setMaxTotal(node.getNode("compatibility-max-connections").getInt(3));
config.setBlockWhenExhausted(true); config.setBlockWhenExhausted(true);
jedisPool = new JedisPool(config, redisServer, redisPort, 0, redisPassword, useSSL); jedisPool = new JedisPool(config, redisServer, redisPort, 0, redisPassword, useSSL);
plugin.logInfo("Compatibility JedisPool was created");
} }
GenericObjectPoolConfig<Connection> poolConfig = new GenericObjectPoolConfig<>(); GenericObjectPoolConfig<Connection> poolConfig = new GenericObjectPoolConfig<>();
poolConfig.setMaxTotal(maxConnections); poolConfig.setMaxTotal(maxConnections);

12
RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/api/summoners/JedisPooledSummoner.java
View File

@ -14,10 +14,16 @@ public class JedisPooledSummoner implements Summoner<JedisPooled> {
public JedisPooledSummoner(JedisPooled jedisPooled, JedisPool jedisPool) { public JedisPooledSummoner(JedisPooled jedisPooled, JedisPool jedisPool) {
this.jedisPooled = jedisPooled; this.jedisPooled = jedisPooled;
this.jedisPool = jedisPool; this.jedisPool = jedisPool;
try (Jedis jedis = this.jedisPool.getResource()) { // test connections
// Test the connection to make sure configuration is right if (jedisPool != null) {
jedis.ping(); try (Jedis jedis = this.jedisPool.getResource()) {
// Test the connection to make sure configuration is right
jedis.ping();
}
} }
jedisPooled.set("random_data", "0");
jedisPooled.del("random_data");
} }
@Override @Override