Skip to content

Commit 204d04b

Browse files
authored
Merge pull request #26 from Streamline-Essentials/dev
Auto PR: Merge dev into master
2 parents 34ef7fa + 39be839 commit 204d04b

3 files changed

Lines changed: 4 additions & 15 deletions

File tree

singularity-api/src/main/java/singularity/configs/given/GivenConfigs.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -33,9 +33,6 @@ public class GivenConfigs {
3333
@Getter @Setter
3434
private static CoreDBOperator mainDatabase;
3535

36-
@Getter @Setter
37-
private static RedisClient redisClient;
38-
3936
public static void init() {
4037
setMainConfig(new MainConfigHandler());
4138
setMainMessages(new MainMessagesHandler());
@@ -53,12 +50,6 @@ public static void init() {
5350
} catch (Exception e) {
5451
e.printStackTrace();
5552
}
56-
57-
try {
58-
setRedisClient(new RedisClient());
59-
} catch (Exception e) {
60-
e.printStackTrace();
61-
}
6253
}
6354

6455
public static void ensureFolders() {

singularity-api/src/main/java/singularity/redis/RedisClient.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,6 @@ public static void withJedis(Consumer<Jedis> consumer, boolean silent) {
7575
});
7676
}
7777

78-
public static RedisClient getInstance() {
79-
return GivenConfigs.getRedisClient();
80-
}
81-
8278
public static void sendMessage(RedisMessage message) {
8379
withJedis(j -> j.publish(message.getChannel(), message.getMessage()));
8480
}

singularity-api/src/main/java/singularity/redis/RedisListener.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import singularity.utils.MessageUtils;
88

99
@Getter @Setter
10-
public abstract class RedisListener extends JedisPubSub implements Identifiable {
10+
public class RedisListener extends JedisPubSub implements Identifiable {
1111
private String identifier;
1212

1313
public RedisListener(String identifier) {
@@ -39,5 +39,7 @@ public void registerAndLoad() {
3939
load();
4040
}
4141

42-
abstract String[] getChannelsArray();
42+
public String[] getChannelsArray() {
43+
return new String[] {};
44+
}
4345
}

0 commit comments

Comments
 (0)