From a0f6bc4ef66dcfcb0796d3fe5e8b9140d1436c90 Mon Sep 17 00:00:00 2001 From: JinYi Date: Thu, 20 Dec 2018 00:07:57 +0800 Subject: [PATCH] =?UTF-8?q?bug=20fix=20RedisService.subscribe()=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E4=B8=AD=EF=BC=8C=E8=8E=B7=E5=8F=96Jedis=E7=9A=84?= =?UTF-8?q?=E6=96=B9=E5=BC=8F=E6=94=B9=E4=B8=BAgetJedis()=EF=BC=8C?= =?UTF-8?q?=E5=B9=B6=E5=8A=A0=E4=B8=8Afinally=E8=AF=AD=E5=8F=A5=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/org/nutz/integration/jedis/RedisService.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java b/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java index 8772aa95..94848489 100644 --- a/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java +++ b/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java @@ -5388,7 +5388,10 @@ public class RedisService extends Jedis { } public void subscribe(JedisPubSub jedisPubSub, String... channels) { - jedis().subscribe(jedisPubSub, channels); + Jedis jedis = getJedis(); + try { + jedis.subscribe(jedisPubSub, channels); + } finally {Streams.safeClose(jedis);} } public Set zrevrangeByLex(byte[] key, byte[] max, byte[] min, int offset, int count) { -- Gitee