Feature - ScoredSortedSetAddListener, ScoredSortedSetRemoveListener added to RScoredSortedSet object. #220

redisson/src/main/java/org/redisson/RedissonScoredSortedSet.java

@@ -17,6 +17,7 @@ package org.redisson;
 
 import org.redisson.api.*;
 import org.redisson.api.listener.ScoredSortedSetAddListener;
+import org.redisson.api.listener.ScoredSortedSetRemoveListener;
 import org.redisson.api.mapreduce.RCollectionMapReduce;
 import org.redisson.client.RedisClient;
 import org.redisson.client.codec.*;
@@ -1828,6 +1829,9 @@ public class RedissonScoredSortedSet<V> extends RedissonExpirable implements RSc
         if (listener instanceof ScoredSortedSetAddListener) {
             return addListener("__keyevent@*:zadd", (ScoredSortedSetAddListener) listener, ScoredSortedSetAddListener::onAdd);
         }
+        if (listener instanceof ScoredSortedSetRemoveListener) {
+            return addListener("__keyevent@*:zrem", (ScoredSortedSetRemoveListener) listener, ScoredSortedSetRemoveListener::onRemove);
+        }
         return super.addListener(listener);
     }
 
@@ -1836,6 +1840,9 @@ public class RedissonScoredSortedSet<V> extends RedissonExpirable implements RSc
         if (listener instanceof ScoredSortedSetAddListener) {
             return addListenerAsync("__keyevent@*:zadd", (ScoredSortedSetAddListener) listener, ScoredSortedSetAddListener::onAdd);
         }
+        if (listener instanceof ScoredSortedSetRemoveListener) {
+            return addListenerAsync("__keyevent@*:zrem", (ScoredSortedSetRemoveListener) listener, ScoredSortedSetRemoveListener::onRemove);
+        }
         return super.addListenerAsync(listener);
     }
 

redisson/src/main/java/org/redisson/api/RScoredSortedSet.java

@@ -1286,4 +1286,17 @@ public interface RScoredSortedSet<V> extends RScoredSortedSetAsync<V>, Iterable<
      */
     int diff(String... names);
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.ScoredSortedSetAddListener
+     * @see org.redisson.api.listener.ScoredSortedSetRemoveListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    int addListener(ObjectListener listener);
+
 }

redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java

@@ -1176,4 +1176,17 @@ public interface RScoredSortedSetReactive<V> extends RExpirableReactive, RSortab
      */
     Flux<V> takeLastElements();
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.ScoredSortedSetAddListener
+     * @see org.redisson.api.listener.ScoredSortedSetRemoveListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    Mono<Integer> addListener(ObjectListener listener);
+
 }

redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java

@@ -1178,5 +1178,19 @@ public interface RScoredSortedSetRx<V> extends RExpirableRx, RSortableRx<Set<V>>
      * @return stream of tail elements
      */
     Flowable<V> takeLastElements();
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.ScoredSortedSetAddListener
+     * @see org.redisson.api.listener.ScoredSortedSetRemoveListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    Single<Integer> addListener(ObjectListener listener);
+
+
 }

redisson/src/main/java/org/redisson/api/listener/ScoredSortedSetRemoveListener.java

@@ -0,0 +1,37 @@
+/**
+ * Copyright (c) 2013-2022 Nikita Koksharov
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.redisson.api.listener;
+
+import org.redisson.api.ObjectListener;
+
+/**
+ * Redisson Object Event listener for <b>zrem</b> event published by Redis.
+ * <p>
+ * Redis notify-keyspace-events setting should contain Ez letters
+ * 
+ * @author Nikita Koksharov
+ *
+ */
+public interface ScoredSortedSetRemoveListener extends ObjectListener {
+
+    /**
+     * Invoked when entry removed from RScoredSortedSet object
+     * 
+     * @param name - name of object
+     */
+    void onRemove(String name);
+    
+}