From 3e691b15023e94675f7e3e1d4319d5594e9f1789 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 14 Jan 2019 19:09:56 +0300 Subject: [PATCH] refactoring --- .../java/org/redisson/pubsub/PublishSubscribeService.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java index 9742e61ff..fa0cf5d03 100644 --- a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java +++ b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java @@ -304,12 +304,8 @@ public class PublishSubscribeService { } public RFuture unsubscribe(final ChannelName channelName, final AsyncSemaphore lock) { - if (connectionManager.isShuttingDown()) { - return RedissonPromise.newSucceededFuture(null); - } - final PubSubConnectionEntry entry = name2PubSubConnection.remove(channelName); - if (entry == null) { + if (entry == null || connectionManager.isShuttingDown()) { lock.release(); return RedissonPromise.newSucceededFuture(null); }