Repo-Mirror/HuskSync
9
0
Fork 0
mirror of https://github.com/WiIIiam278/HuskSync.git synced 2025-12-26 01:59:20 +00:00
Code Issues Releases 1 Activity

Authenticate redis after establishing connection

Browse Source
This commit is contained in:
William
2021-12-23 23:08:35 +00:00
parent 911bdbc400
commit 8241d64d11
2 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
common/src/main/java/me/william278/husksync/redis/RedisListener.java
View File

@@ -2,6 +2,7 @@ package me.william278.husksync.redis;
import me.william278.husksync.Settings;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisClientConfig;
import redis.clients.jedis.JedisPubSub;
import redis.clients.jedis.exceptions.JedisException;
@@ -17,13 +18,15 @@ public abstract class RedisListener {
/**
* Handle an incoming {@link RedisMessage}
*
* @param message The {@link RedisMessage} to handle
*/
public abstract void handleMessage(RedisMessage message);
/**
* Log to console
* @param level The {@link Level} to log
*
* @param level The {@link Level} to log
* @param message Message to log
*/
public abstract void log(Level level, String message);
@@ -32,15 +35,15 @@ public abstract class RedisListener {
* Start the Redis listener
*/
public final void listen() {
try(Jedis jedis = new Jedis(Settings.redisHost, Settings.redisPort)) {
try (Jedis jedis = new Jedis(Settings.redisHost, Settings.redisPort)) {
final String jedisPassword = Settings.redisPassword;
if (!jedisPassword.equals("")) {
jedis.auth(jedisPassword);
}
jedis.connect();
if (jedis.isConnected()) {
if (!jedisPassword.equals("")) {
jedis.auth(jedisPassword);
}
isActiveAndEnabled = true;
log(Level.INFO,"Enabled Redis listener successfully!");
log(Level.INFO, "Enabled Redis listener successfully!");
new Thread(() -> jedis.subscribe(new JedisPubSub() {
@Override
public void onMessage(String channel, String message) {

2
common/src/main/java/me/william278/husksync/redis/RedisMessage.java
View File

@@ -63,10 +63,10 @@ public class RedisMessage {
public void send() throws IOException {
try (Jedis publisher = new Jedis(Settings.redisHost, Settings.redisPort)) {
final String jedisPassword = Settings.redisPassword;
publisher.connect();
if (!jedisPassword.equals("")) {
publisher.auth(jedisPassword);
}
publisher.connect();
publisher.publish(REDIS_CHANNEL, getFullMessage());
}
}