Feature - RMapCacheNative implementation which uses Redis 7.4+ commands #5954

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

@@ -281,4 +281,19 @@ public interface RMapCacheNative<K, V> extends RMap<K, V>, RMapCacheNativeAsync<
      */
     int expireEntriesIfNotSet(Set<K> keys, Duration ttl);
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.MapExpiredListener
+     * @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/RMapCacheNativeAsync.java

@@ -281,5 +281,19 @@ public interface RMapCacheNativeAsync<K, V> extends RMapAsync<K, V> {
      */
     RFuture<Integer> expireEntriesIfLessAsync(Set<K> keys, Duration ttl);
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.MapExpiredListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    RFuture<Integer> addListenerAsync(ObjectListener listener);
 
 }

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

@@ -281,4 +281,19 @@ public interface RMapCacheNativeReactive<K, V> extends RMapReactive<K, V>, RDest
      */
     Mono<Integer> expireEntriesIfNotSet(Set<K> keys, Duration ttl);
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.MapExpiredListener
+     * @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/RMapCacheNativeRx.java

@@ -284,4 +284,19 @@ public interface RMapCacheNativeRx<K, V> extends RMapRx<K, V>, RDestroyable {
      */
     Single<Integer> expireEntriesIfNotSet(Set<K> keys, Duration ttl);
 
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.listener.TrackingListener
+     * @see org.redisson.api.listener.MapPutListener
+     * @see org.redisson.api.listener.MapRemoveListener
+     * @see org.redisson.api.listener.MapExpiredListener
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    Single<Integer> addListener(ObjectListener listener);
+
 }