Feature - RLocalCachedMap.removeListener() method doesn't remove local cache listeners

pull/5004/head
Nikita Koksharov 2 years ago
parent 4fe0d58b07
commit ebdbbd595f

@ -1323,4 +1323,16 @@ public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements R
}
return super.addListenerAsync(listener);
}
@Override
public void removeListener(int listenerId) {
listener.removeListener(listenerId);
super.removeListener(listenerId);
}
@Override
public RFuture<Void> removeListenerAsync(int listenerId) {
listener.removeListener(listenerId);
return super.removeListenerAsync(listenerId);
}
}

@ -382,4 +382,9 @@ public abstract class LocalCacheListener {
return listenerId;
}
public void removeListener(int listenerId) {
updateListeners.remove(listenerId);
invalidateListeners.remove(listenerId);
}
}

Loading…
Cancel
Save