Plex/server/src/main/java/dev/plex/storage/RedisConnection.java

48 lines
1.1 KiB
Java
Raw Normal View History

2021-01-03 07:21:15 +00:00
package dev.plex.storage;
import dev.plex.PlexBase;
import dev.plex.util.PlexLog;
import java.util.function.Consumer;
2022-03-17 22:16:17 +00:00
import redis.clients.jedis.Jedis;
2022-04-17 05:27:04 +00:00
public class RedisConnection implements PlexBase
{
private Jedis jedis;
2022-02-04 19:30:05 +00:00
public Jedis getJedis()
{
try
{
jedis = new Jedis(plugin.config.getString("data.side.hostname"),
plugin.config.getInt("data.side.port"));
if (plugin.config.getBoolean("data.side.auth"))
{
jedis.auth(plugin.config.getString("data.side.password"));
}
return jedis;
}
catch (Exception ex)
{
PlexLog.error("An error occurred with Redis.");
ex.printStackTrace();
}
return jedis;
}
public void runAsync(Consumer<Jedis> jedisConsumer)
{
new Thread(() ->
{
try (Jedis jedis = getJedis())
{
jedisConsumer.accept(jedis);
}
}).start();
}
public final boolean isEnabled()
{
return plugin.config.getBoolean("data.side.enabled");
}
}