Feature - added TrackingListener support to RList, RQueue, RDeque, RBlockingQueue, RBlockingDeque, RDelayedQueue, RRingBuffer objects #5647

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

@@ -15,12 +15,12 @@
  */
 package org.redisson.api;
 
+import org.redisson.api.mapreduce.RCollectionMapReduce;
+
 import java.util.Iterator;
 import java.util.List;
 import java.util.RandomAccess;
 
-import org.redisson.api.mapreduce.RCollectionMapReduce;
-
 /**
  * Distributed and concurrent implementation of {@link java.util.List}
  *
@@ -151,6 +151,7 @@ public interface RList<V> extends List<V>, RExpirable, RListAsync<V>, RSortable<
     /**
      * Adds object event listener
      *
+     * @see org.redisson.api.listener.TrackingListener
      * @see org.redisson.api.ExpiredObjectListener
      * @see org.redisson.api.DeletedObjectListener
      * @see org.redisson.api.listener.ListAddListener

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

@@ -181,5 +181,22 @@ public interface RListReactive<V> extends RCollectionReactive<V>, RSortableReact
      * @return elements
      */
     Mono<List<V>> range(int fromIndex, int toIndex);
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     * @see org.redisson.api.listener.ListAddListener
+     * @see org.redisson.api.listener.ListInsertListener
+     * @see org.redisson.api.listener.ListSetListener
+     * @see org.redisson.api.listener.ListRemoveListener
+     * @see org.redisson.api.listener.ListTrimListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    Mono<Integer> addListener(ObjectListener listener);
+
 }

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

@@ -183,5 +183,22 @@ public interface RListRx<V> extends RCollectionRx<V>, RSortableRx<List<V>> {
      * @return elements
      */
     Single<List<V>> range(int fromIndex, int toIndex);
-    
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     * @see org.redisson.api.listener.ListAddListener
+     * @see org.redisson.api.listener.ListInsertListener
+     * @see org.redisson.api.listener.ListSetListener
+     * @see org.redisson.api.listener.ListRemoveListener
+     * @see org.redisson.api.listener.ListTrimListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    Single<Integer> addListener(ObjectListener listener);
+
 }

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

@@ -54,6 +54,7 @@ public interface RQueue<V> extends Queue<V>, RExpirable, RQueueAsync<V> {
     /**
      * Adds object event listener
      *
+     * @see org.redisson.api.listener.TrackingListener
      * @see org.redisson.api.ExpiredObjectListener
      * @see org.redisson.api.DeletedObjectListener
      * @see org.redisson.api.listener.ListAddListener

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

@@ -78,6 +78,7 @@ public interface RQueueAsync<V> extends RCollectionAsync<V> {
     /**
      * Adds object event listener
      *
+     * @see org.redisson.api.listener.TrackingListener
      * @see org.redisson.api.ExpiredObjectListener
      * @see org.redisson.api.DeletedObjectListener
      * @see org.redisson.api.listener.ListAddListener

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

@@ -77,4 +77,21 @@ public interface RQueueReactive<V> extends RCollectionReactive<V> {
      */
     Mono<List<V>> readAll();
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     * @see org.redisson.api.listener.ListAddListener
+     * @see org.redisson.api.listener.ListInsertListener
+     * @see org.redisson.api.listener.ListSetListener
+     * @see org.redisson.api.listener.ListRemoveListener
+     * @see org.redisson.api.listener.ListTrimListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    Mono<Integer> addListener(ObjectListener listener);
+
 }

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

@@ -77,4 +77,22 @@ public interface RQueueRx<V> extends RCollectionRx<V> {
      * @return elements
      */
     Single<List<V>> readAll();
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     * @see org.redisson.api.listener.ListAddListener
+     * @see org.redisson.api.listener.ListInsertListener
+     * @see org.redisson.api.listener.ListSetListener
+     * @see org.redisson.api.listener.ListRemoveListener
+     * @see org.redisson.api.listener.ListTrimListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    Single<Integer> addListener(ObjectListener listener);
+
 }