Merge branch 'master' into 3.0.0

pull/1933/head
Nikita Koksharov 6 years ago
commit 5e5ac70cba

@ -304,12 +304,8 @@ public class PublishSubscribeService {
} }
public RFuture<Void> unsubscribe(final ChannelName channelName, final AsyncSemaphore lock) { public RFuture<Void> unsubscribe(final ChannelName channelName, final AsyncSemaphore lock) {
if (connectionManager.isShuttingDown()) {
return RedissonPromise.newSucceededFuture(null);
}
final PubSubConnectionEntry entry = name2PubSubConnection.remove(channelName); final PubSubConnectionEntry entry = name2PubSubConnection.remove(channelName);
if (entry == null) { if (entry == null || connectionManager.isShuttingDown()) {
lock.release(); lock.release();
return RedissonPromise.newSucceededFuture(null); return RedissonPromise.newSucceededFuture(null);
} }

Loading…
Cancel
Save