diff --git a/redisson/src/main/java/org/redisson/RedissonAtomicDouble.java b/redisson/src/main/java/org/redisson/RedissonAtomicDouble.java index 660eeb0b5..79468d914 100644 --- a/redisson/src/main/java/org/redisson/RedissonAtomicDouble.java +++ b/redisson/src/main/java/org/redisson/RedissonAtomicDouble.java @@ -199,7 +199,7 @@ public class RedissonAtomicDouble extends RedissonExpirable implements RAtomicDo @Override public RFuture removeListenerAsync(int listenerId) { - return removeListenerAsync(super.removeListenerAsync(listenerId), listenerId, "__keyevent@*:incrby"); + return removeListenerAsync(listenerId, "__keyevent@*:incrby"); } } diff --git a/redisson/src/main/java/org/redisson/RedissonAtomicLong.java b/redisson/src/main/java/org/redisson/RedissonAtomicLong.java index 931de4838..686b84cb1 100644 --- a/redisson/src/main/java/org/redisson/RedissonAtomicLong.java +++ b/redisson/src/main/java/org/redisson/RedissonAtomicLong.java @@ -197,7 +197,7 @@ public class RedissonAtomicLong extends RedissonExpirable implements RAtomicLong @Override public RFuture removeListenerAsync(int listenerId) { - return removeListenerAsync(super.removeListenerAsync(listenerId), listenerId, "__keyevent@*:incrby"); + return removeListenerAsync(listenerId, "__keyevent@*:incrby"); } } diff --git a/redisson/src/main/java/org/redisson/RedissonMap.java b/redisson/src/main/java/org/redisson/RedissonMap.java index bc644ba87..17d16662b 100644 --- a/redisson/src/main/java/org/redisson/RedissonMap.java +++ b/redisson/src/main/java/org/redisson/RedissonMap.java @@ -1770,7 +1770,7 @@ public class RedissonMap extends RedissonExpirable implements RMap { @Override public RFuture removeListenerAsync(int listenerId) { RFuture f1 = removeTrackingListenerAsync(listenerId); - RFuture f2 = removeListenerAsync(super.removeListenerAsync(listenerId), listenerId, "__keyevent@*:hset", "__keyevent@*:hdel"); + RFuture f2 = removeListenerAsync(listenerId, "__keyevent@*:hset", "__keyevent@*:hdel"); return new CompletableFutureWrapper<>(CompletableFuture.allOf(f1.toCompletableFuture(), f2.toCompletableFuture())); } diff --git a/redisson/src/main/java/org/redisson/RedissonStream.java b/redisson/src/main/java/org/redisson/RedissonStream.java index 875943b43..679306c4f 100644 --- a/redisson/src/main/java/org/redisson/RedissonStream.java +++ b/redisson/src/main/java/org/redisson/RedissonStream.java @@ -880,7 +880,7 @@ public class RedissonStream extends RedissonExpirable implements RStream removeListenerAsync(int listenerId) { RFuture f1 = removeTrackingListenerAsync(listenerId); - RFuture f2 = removeListenerAsync(super.removeListenerAsync(listenerId), listenerId, + RFuture f2 = removeListenerAsync(listenerId, "__keyevent@*:xadd", "__keyevent@*:xdel", "__keyevent@*:xgroup-createconsumer", "__keyevent@*:xgroup-delconsumer", "__keyevent@*:xgroup-create", "__keyevent@*:xgroup-destroy", "__keyevent@*:xtrim"); return new CompletableFutureWrapper<>(CompletableFuture.allOf(f1.toCompletableFuture(), f2.toCompletableFuture()));