refactoring

pull/5679/head
Nikita Koksharov 1 year ago
parent 506bd9a2e5
commit 018e97bc77

@ -524,6 +524,11 @@ public abstract class RedissonObject implements RObject {
protected final RFuture<Void> removeTrackingListenerAsync(int listenerId) {
PublishSubscribeService subscribeService = commandExecutor.getConnectionManager().getSubscribeService();
ChannelName cn = new ChannelName("__redis__:invalidate");
if (!subscribeService.hasEntry(cn)) {
return new CompletableFutureWrapper<>((Void) null);
}
CompletableFuture<Void> f = subscribeService.removeListenerAsync(PubSubType.UNSUBSCRIBE, new ChannelName("__redis__:invalidate"), listenerId);
f = f.whenComplete((r, e) -> {
if (!commandExecutor.isTrackChanges()) {

Loading…
Cancel
Save