Skip to content

Commit d7a57ae

Browse files
author
lightplugins
committed
updated to 0.3.3
1 parent a603cea commit d7a57ae

File tree

3 files changed

+12
-11
lines changed

3 files changed

+12
-11
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55

66
<groupId>io.lightstudios.core</groupId>
77
<artifactId>lightCore</artifactId>
8-
<version>0.3.2</version>
8+
<version>0.3.3</version>
99

1010
<organization>
1111
<name>lightPlugins</name>

src/main/java/io/lightstudios/core/redis/messaging/RedisSubscriber.java

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import io.lightstudios.core.LightCore;
44
import io.lightstudios.core.util.interfaces.LightRedisSub;
5-
import redis.clients.jedis.JedisPooled;
5+
import redis.clients.jedis.Jedis;
66
import redis.clients.jedis.JedisPubSub;
77

88
import java.util.ArrayList;
@@ -20,14 +20,15 @@ public RedisSubscriber(ArrayList<LightRedisSub> lightRedisListeners, String chan
2020
}
2121

2222
private void receiveData() {
23-
JedisPooled jedis = LightCore.instance.getRedisManager().getJedisPooled();
24-
jedis.subscribe(new JedisPubSub() {
25-
@Override
26-
public void onMessage(String channel, String message) {
27-
for(LightRedisSub lightRedisSub : lightRedisListeners) {
28-
lightRedisSub.receiveData(channel, message);
23+
try(Jedis jedis = LightCore.instance.getRedisManager().getJedisPool().getResource()) {
24+
jedis.subscribe(new JedisPubSub() {
25+
@Override
26+
public void onMessage(String channel, String message) {
27+
for(LightRedisSub lightRedisSub : lightRedisListeners) {
28+
lightRedisSub.receiveData(channel, message);
29+
}
2930
}
30-
}
31-
}, this.channelName);
31+
}, this.channelName);
32+
}
3233
}
3334
}

src/main/resources/plugin.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
name: lightCore
22
author: LightStudios
3-
version: '0.3.2'
3+
version: '0.3.3'
44
main: io.lightstudios.core.LightCore
55
api-version: 1.21
66
depend: ["Vault"]

0 commit comments

Comments
 (0)