Feature - ability to add listeners for RListMultimap and RSetMultimap objects. #2058

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

@@ -80,6 +80,7 @@ public interface RListMultimap<K, V> extends RMultimap<K, V> {
      * @param listener object event listener
      * @return listener id
      */
+    @Override
     int addListener(ObjectListener listener);
 
 
@@ -96,6 +97,7 @@ public interface RListMultimap<K, V> extends RMultimap<K, V> {
      * @param listener object event listener
      * @return listener id
      */
+    @Override
     RFuture<Integer> addListenerAsync(ObjectListener listener);
 
 }

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

@@ -79,5 +79,21 @@ public interface RListMultimapReactive<K, V> extends RMultimapReactive<K, V> {
      *     multimap.
      */
     Mono<List<V>> replaceValues(K key, Iterable<? extends V> values);
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.ListAddListener
+     * @see org.redisson.api.listener.ListRemoveListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    @Override
+    Mono<Integer> addListener(ObjectListener listener);
+
 }

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

@@ -79,5 +79,21 @@ public interface RListMultimapRx<K, V> extends RMultimapRx<K, V> {
      *     multimap.
      */
     Single<List<V>> replaceValues(K key, Iterable<? extends V> values);
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.ListAddListener
+     * @see org.redisson.api.listener.ListRemoveListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    @Override
+    Single<Integer> addListener(ObjectListener listener);
+
 }

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

@@ -79,5 +79,20 @@ public interface RSetMultimapReactive<K, V> extends RMultimapReactive<K, V> {
      *     multimap.
      */
     Mono<Set<V>> replaceValues(K key, Iterable<? extends V> values);
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.SetAddListener
+     * @see org.redisson.api.listener.SetRemoveListener
+     * @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/RSetMultimapRx.java

@@ -79,5 +79,20 @@ public interface RSetMultimapRx<K, V> extends RMultimapRx<K, V> {
      *     multimap.
      */
     Single<Set<V>> replaceValues(K key, Iterable<? extends V> values);
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.SetAddListener
+     * @see org.redisson.api.listener.SetRemoveListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    Single<Integer> addListener(ObjectListener listener);
+
 }