diff --git a/redisson/src/main/java/org/redisson/api/RJsonStore.java b/redisson/src/main/java/org/redisson/api/RJsonStore.java
new file mode 100644
index 000000000..afa0a9dc5
--- /dev/null
+++ b/redisson/src/main/java/org/redisson/api/RJsonStore.java
@@ -0,0 +1,893 @@
+/**
+ * Copyright (c) 2013-2024 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;
+
+import org.redisson.codec.JsonCodec;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * JSON Store which stores each entry as key and value. Both are POJO objects.
+ * Value is stored as JSON datatype in Redis.
+ * <p>
+ * The implementation is available in Redisson PRO only.
+ *
+ * @author Nikita Koksharov
+ *
+ * @param <K> the type of key
+ * @param <V> the type of value
+ *
+ */
+public interface RJsonStore<K, V> extends RExpirable, RJsonStoreAsync<K, V> {
+
+    /**
+     * Gets value by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param paths JSON paths
+     * @return entry value
+     *
+     * @param <T> the type of object
+     */
+    <T> T get(K key, JsonCodec codec, String... paths);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value entry value
+     * @return {@code true} if successful, or {@code false} if
+     *         value was already set
+     */
+    boolean setIfAbsent(K key, String path, Object value);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is non-empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value object
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    boolean setIfExists(K key, String path, Object value);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key and JSONPath, only if serialized state of
+     * the current value equals to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    boolean compareAndSet(K key, String path, Object expect, Object update);
+
+    /**
+     * Retrieves current value stored by specified key and JSONPath then
+     * replaces it with new value.
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param path JSON path
+     * @param newValue value to set
+     * @return previous value
+     */
+    <T> T getAndSet(K key, JsonCodec codec, String path, Object newValue);
+
+    /**
+     * Stores value by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to set
+     */
+    void set(K key, String path, Object value);
+
+    /**
+     * Returns size of string data by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of string
+     */
+    Long stringSize(K key, String path);
+
+    /**
+     * Returns list of string data size by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of string data sizes
+     */
+    List<Long> stringSizeMulti(K key, String path);
+
+    /**
+     * Appends string data to element specified by specified key and JSONPath.
+     * Returns new size of string data.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return size of string data
+     */
+    long stringAppend(K key, String path, Object value);
+
+    /**
+     * Appends string data to elements specified by specified key and JSONPath.
+     * Returns new size of string data.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return list of string data sizes
+     */
+    List<Long> stringAppendMulti(K key, String path, Object value);
+
+    /**
+     * Appends values to array by specified key and JSONPath.
+     * Returns new size of array.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return size of array
+     */
+    long arrayAppend(K key, String path, Object... values);
+
+    /**
+     * Appends values to arrays by specified key and JSONPath.
+     * Returns new size of arrays.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return list of arrays size
+     */
+    List<Long> arrayAppendMulti(K key, String path, Object... values);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return index in array
+     */
+    long arrayIndex(K key, String path, Object value);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return list of index in arrays
+     */
+    List<Long> arrayIndexMulti(K key, String path, Object value);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return index in array
+     */
+    long arrayIndex(K key, String path, Object value, long start, long end);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return list of index in arrays
+     */
+    List<Long> arrayIndexMulti(K key, String path, Object value, long start, long end);
+
+    /**
+     * Inserts values into array by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return size of array
+     */
+    long arrayInsert(K key, String path, long index, Object... values);
+
+    /**
+     * Inserts values into arrays by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return list of arrays size
+     */
+    List<Long> arrayInsertMulti(K key, String path, long index, Object... values);
+
+    /**
+     * Returns size of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of array
+     */
+    long arraySize(K key, String path);
+
+    /**
+     * Returns size of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of arrays size
+     */
+    List<Long> arraySizeMulti(K key, String path);
+
+    /**
+     * Polls last element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return last element
+     *
+     * @param <T> the type of object
+     */
+    <T> T arrayPollLast(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls last element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of last elements
+     *
+     * @param <T> the type of object
+     */
+    <T> List<T> arrayPollLastMulti(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return first element
+     *
+     * @param <T> the type of object
+     */
+    <T> T arrayPollFirst(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of first elements
+     *
+     * @param <T> the type of object
+     */
+    <T> List<T> arrayPollFirstMulti(K key, JsonCodec codec, String path);
+
+    /**
+     * Pops element located at index of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return element
+     *
+     * @param <T> the type of object
+     */
+    <T> T arrayPop(K key, JsonCodec codec, String path, long index);
+
+    /**
+     * Pops elements located at index of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return list of elements
+     *
+     * @param <T> the type of object
+     */
+    <T> List<T> arrayPopMulti(K key, JsonCodec codec, String path, long index);
+
+    /**
+     * Trims array by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    long arrayTrim(K key, String path, long start, long end);
+
+    /**
+     * Trims arrays by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    List<Long> arrayTrimMulti(K key, String path, long start, long end);
+
+    /**
+     * Clears value by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    boolean clear(K key);
+
+    /**
+     * Clears json containers by specified keys.
+     *
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    long clear(Set<K> keys);
+
+    /**
+     * Clears json container by specified keys and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    long clear(String path, Set<K> keys);
+
+    /**
+     * Increments the current value specified by key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return the updated value
+     */
+    <T extends Number> T incrementAndGet(K key, String path, T delta);
+
+    /**
+     * Increments the current values specified by key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return list of updated value
+     */
+    <T extends Number> List<T> incrementAndGetMulti(K key, String path, T delta);
+
+    /**
+     * Merges value into element by the specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to merge
+     */
+    void merge(K key, String path, Object value);
+
+    /**
+     * Returns keys amount in JSON container by specified key
+     *
+     * @param key entry key
+     * @return keys amount
+     */
+    long countKeys(K key);
+
+    /**
+     * Returns keys amount in JSON container specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return keys amount
+     */
+    long countKeys(K key, String path);
+
+    /**
+     * Returns list of keys amount in JSON containers specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of keys amount
+     */
+    List<Long> countKeysMulti(K key, String path);
+
+    /**
+     * Returns list of keys in JSON container by specified key
+     *
+     * @return list of keys
+     */
+    List<String> getKeys(K key);
+
+    /**
+     * Returns list of keys in JSON container by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    List<String> getKeys(K key, String path);
+
+    /**
+     * Returns list of keys in JSON containers by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    List<List<String>> getKeysMulti(K key, String path);
+
+    /**
+     * Toggle boolean value by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return new boolean value
+     */
+    boolean toggle(K key, String path);
+
+    /**
+     * Toggle boolean values by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of boolean values
+     */
+    List<Boolean> toggleMulti(K key, String path);
+
+    /**
+     * Returns type of value
+     *
+     * @return type of element
+     */
+    JsonType getType(K key);
+
+    /**
+     * Returns type of element specified by key and JSONPath
+     *
+     * @param path JSON path
+     * @return type of element
+     */
+    JsonType getType(K key, String path);
+
+    /**
+     * Deletes entry by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    boolean delete(K key);
+
+    /**
+     * Deletes entries by specified keys
+     *
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    long delete(Set<K> keys);
+
+    /**
+     * Deletes JSON elements specified by keys and JSONPath
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    long delete(String path, Set<K> keys);
+
+    /**
+     * Returns size of entry in bytes specified by key.
+     *
+     * @param key entry key
+     * @return entry size
+     */
+    long sizeInMemory(K key);
+
+    /**
+     * Retrieves value by specified key.
+     *
+     * @param key entry key
+     * @return element
+     */
+    V get(K key);
+
+    /**
+     * Retrieves values by specified keys.
+     *
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    Map<K, V> get(Set<K> keys);
+
+    /**
+     * Retrieves values by specified keys and JSONPath.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    Map<K, V> get(String path, Set<K> keys);
+
+    /**
+     * Retrieves entry value by specified key and removes it.
+     *
+     * @param key entry key
+     * @return element
+     */
+    V getAndDelete(K key);
+
+    /**
+     * Sets value only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    boolean setIfAbsent(K key, V value);
+
+    /**
+     * Sets value with defined duration only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    boolean setIfAbsent(K key, V value, Duration duration);
+
+    /**
+     * Sets value only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    boolean setIfExists(K key, V value);
+
+    /**
+     * Sets <code>value</code> with expiration <code>duration</code> only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    boolean setIfExists(K key, V value, Duration duration);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key only if serialized state of the current value equals
+     * to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    boolean compareAndSet(K key, V expect, V update);
+
+    /**
+     * Retrieves current value by specified key and replaces it with new value.
+     *
+     * @param key entry key
+     * @param newValue value to set
+     * @return previous value
+     */
+    V getAndSet(K key, V newValue);
+
+    /**
+     * Retrieves current value by specified key and replaces it
+     * with value and defines expiration <code>duration</code>.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return previous value
+     */
+    V getAndSet(K key, V value, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration duration for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param duration of object time to live interval
+     * @return value
+     */
+    V getAndExpire(K key, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration date for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param time of exact object expiration moment
+     * @return value
+     */
+    V getAndExpire(K key, Instant time);
+
+    /**
+     * Retrieves current value by specified key and clears expiration date set before.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @return value
+     */
+    V getAndClearExpire(K key);
+
+    /**
+     * Stores value by specified key.
+     *
+     * @param key entry key
+     * @param value value to set
+     */
+    void set(K key, V value);
+
+    /**
+     * Stores values by specified keys.
+     *
+     * @param entries entries to store
+     */
+    void set(Map<K, V> entries);
+
+    /**
+     * Stores values by specified keys and JSONPath.
+     *
+     * @param path JSONPath
+     * @param entries entries to store
+     */
+    void set(String path, Map<K, V> entries);
+
+    /**
+     * Stores value by specified key with defined expiration duration.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     */
+    void set(K key, V value, Duration duration);
+
+    /**
+     * Stores values by specified keys with defined expiration duration.
+     *
+     * @param entries entries to store
+     * @param duration expiration duration
+     */
+    void set(Map<K, V> entries, Duration duration);
+
+    /**
+     * Sets value by specified key and keep existing TTL.
+     * <p>
+     * Requires <b>Redis 6.0.0 and higher.</b>
+     *
+     * @param value value to set
+     */
+    void setAndKeepTTL(K key, V value);
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     * @see org.redisson.api.listener.SetObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    int addListener(ObjectListener listener);
+
+    /**
+     * Remaining time to live of map entry associated with a <code>key</code>.
+     *
+     * @param key - map key
+     * @return time in milliseconds
+     *          -2 if the key does not exist.
+     *          -1 if the key exists but has no associated expire.
+     */
+    long remainTimeToLive(K key);
+
+    /**
+     * Returns key set of this map.
+     * Keys are loaded in batch. Batch size is <code>10</code>.
+     *
+     * @see #readAllKeySet()
+     *
+     * @return key set
+     */
+    Set<K> keySet();
+
+    /**
+     * Returns key set of this map.
+     * Keys are loaded in batch. Batch size is defined by <code>count</code> param.
+     *
+     * @see #readAllKeySet()
+     *
+     * @param count - size of keys batch
+     * @return key set
+     */
+    Set<K> keySet(int count);
+
+    /**
+     * Returns key set of this map.
+     * If <code>pattern</code> is not null then only keys match this pattern are loaded.
+     * Keys are loaded in batch. Batch size is defined by <code>count</code> param.
+     * <p>
+     * Use <code>org.redisson.client.codec.StringCodec</code> for Map keys.
+     * <p>
+     *
+     *  Supported glob-style patterns:
+     *  <p>
+     *    h?llo subscribes to hello, hallo and hxllo
+     *    <p>
+     *    h*llo subscribes to hllo and heeeello
+     *    <p>
+     *    h[ae]llo subscribes to hello and hallo, but not hillo
+     *
+     * @see #readAllKeySet()
+     *
+     * @param pattern - key pattern
+     * @param count - size of keys batch
+     * @return key set
+     */
+    Set<K> keySet(String pattern, int count);
+
+    /**
+     * Returns key set of this map.
+     * If <code>pattern</code> is not null then only keys match this pattern are loaded.
+     * <p>
+     * Use <code>org.redisson.client.codec.StringCodec</code> for Map keys.
+     * <p>
+     *
+     *  Supported glob-style patterns:
+     *  <p>
+     *    h?llo subscribes to hello, hallo and hxllo
+     *    <p>
+     *    h*llo subscribes to hllo and heeeello
+     *    <p>
+     *    h[ae]llo subscribes to hello and hallo, but not hillo
+     *
+     * @see #readAllKeySet()
+     *
+     * @param pattern - key pattern
+     * @return key set
+     */
+    Set<K> keySet(String pattern);
+
+    /**
+     * Returns <code>true</code> if this map contains map entry
+     * mapped by specified <code>key</code>, otherwise <code>false</code>
+     *
+     * @param key - map key
+     * @return <code>true</code> if this map contains map entry
+     *          mapped by specified <code>key</code>, otherwise <code>false</code>
+     */
+    boolean containsKey(Object key);
+
+    /**
+     * Read all keys at once
+     *
+     * @return keys
+     */
+    Set<K> readAllKeySet();
+
+    /**
+     * Returns entries amount in store
+     *
+     * @return entries amount
+     */
+    int size();
+
+    /**
+     * Returns <code>RCountDownLatch</code> instance associated with key
+     *
+     * @param key - map key
+     * @return countdownlatch
+     */
+    RCountDownLatch getCountDownLatch(K key);
+
+    /**
+     * Returns <code>RPermitExpirableSemaphore</code> instance associated with key
+     *
+     * @param key - map key
+     * @return permitExpirableSemaphore
+     */
+    RPermitExpirableSemaphore getPermitExpirableSemaphore(K key);
+
+    /**
+     * Returns <code>RSemaphore</code> instance associated with key
+     *
+     * @param key - map key
+     * @return semaphore
+     */
+    RSemaphore getSemaphore(K key);
+
+    /**
+     * Returns <code>RLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return fairlock
+     */
+    RLock getFairLock(K key);
+
+    /**
+     * Returns <code>RReadWriteLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return readWriteLock
+     */
+    RReadWriteLock getReadWriteLock(K key);
+
+    /**
+     * Returns <code>RLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return lock
+     */
+    RLock getLock(K key);
+
+}
diff --git a/redisson/src/main/java/org/redisson/api/RJsonStoreAsync.java b/redisson/src/main/java/org/redisson/api/RJsonStoreAsync.java
new file mode 100644
index 000000000..ead018f43
--- /dev/null
+++ b/redisson/src/main/java/org/redisson/api/RJsonStoreAsync.java
@@ -0,0 +1,792 @@
+/**
+ * Copyright (c) 2013-2024 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;
+
+import org.redisson.codec.JsonCodec;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * JSON Store which stores each entry as key and value. Both are POJO objects.
+ * Value is stored as JSON datatype in Redis.
+ * <p>
+ * The implementation is available in Redisson PRO only.
+ *
+ * @author Nikita Koksharov
+ *
+ * @param <K> the type of key
+ * @param <V> the type of value
+ *
+ */
+public interface RJsonStoreAsync<K, V> extends RExpirableAsync {
+
+    /**
+     * Gets value by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param paths JSON paths
+     * @return entry value
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<T> getAsync(K key, JsonCodec codec, String... paths);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value entry value
+     * @return {@code true} if successful, or {@code false} if
+     *         value was already set
+     */
+    RFuture<Boolean> setIfAbsentAsync(K key, String path, Object value);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is non-empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value object
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    RFuture<Boolean> setIfExistsAsync(K key, String path, Object value);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key and JSONPath, only if serialized state of
+     * the current value equals to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    RFuture<Boolean> compareAndSetAsync(K key, String path, Object expect, Object update);
+
+    /**
+     * Retrieves current value stored by specified key and JSONPath then
+     * replaces it with new value.
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param path JSON path
+     * @param newValue value to set
+     * @return previous value
+     */
+    <T> RFuture<T> getAndSetAsync(K key, JsonCodec codec, String path, Object newValue);
+
+    /**
+     * Stores value by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to set
+     */
+    RFuture<Void> setAsync(K key, String path, Object value);
+
+    /**
+     * Returns size of string data by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of string
+     */
+    RFuture<Long> stringSizeAsync(K key, String path);
+
+    /**
+     * Returns list of string data size by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of string data sizes
+     */
+    RFuture<List<Long>> stringSizeMultiAsync(K key, String path);
+
+    /**
+     * Appends string data to element specified by specified key and JSONPath.
+     * Returns new size of string data.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return size of string data
+     */
+    RFuture<Long> stringAppendAsync(K key, String path, Object value);
+
+    /**
+     * Appends string data to elements by specified key and JSONPath.
+     * Returns new size of string data.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return list of string data sizes
+     */
+    RFuture<List<Long>> stringAppendMultiAsync(K key, String path, Object value);
+
+    /**
+     * Appends values to array by specified key and JSONPath.
+     * Returns new size of array.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return size of array
+     */
+    RFuture<Long> arrayAppendAsync(K key, String path, Object... values);
+
+    /**
+     * Appends values to arrays by specified key and JSONPath.
+     * Returns new size of arrays.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return list of arrays size
+     */
+    RFuture<List<Long>> arrayAppendMultiAsync(K key, String path, Object... values);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return index in array
+     */
+    RFuture<Long> arrayIndexAsync(K key, String path, Object value);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return list of index in arrays
+     */
+    RFuture<List<Long>> arrayIndexMultiAsync(K key, String path, Object value);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return index in array
+     */
+    RFuture<Long> arrayIndexAsync(K key, String path, Object value, long start, long end);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return list of index in arrays
+     */
+    RFuture<List<Long>> arrayIndexMultiAsync(K key, String path, Object value, long start, long end);
+
+    /**
+     * Inserts values into array by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return size of array
+     */
+    RFuture<Long> arrayInsertAsync(K key, String path, long index, Object... values);
+
+    /**
+     * Inserts values into arrays by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return list of arrays size
+     */
+    RFuture<List<Long>> arrayInsertMultiAsync(K key, String path, long index, Object... values);
+
+    /**
+     * Returns size of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of array
+     */
+    RFuture<Long> arraySizeAsync(K key, String path);
+
+    /**
+     * Returns size of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of arrays size
+     */
+    RFuture<List<Long>> arraySizeMultiAsync(K key, String path);
+
+    /**
+     * Polls last element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return last element
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<T> arrayPollLastAsync(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls last element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of last elements
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<List<T>> arrayPollLastMultiAsync(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return first element
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<T> arrayPollFirstAsync(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of first elements
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<List<T>> arrayPollFirstMultiAsync(K key, JsonCodec codec, String path);
+
+    /**
+     * Pops element located at index of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return element
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<T> arrayPopAsync(K key, JsonCodec codec, String path, long index);
+
+    /**
+     * Pops elements located at index of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return list of elements
+     *
+     * @param <T> the type of object
+     */
+    <T> RFuture<List<T>> arrayPopMultiAsync(K key, JsonCodec codec, String path, long index);
+
+    /**
+     * Trims array by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    RFuture<Long> arrayTrimAsync(K key, String path, long start, long end);
+
+    /**
+     * Trims arrays by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    RFuture<List<Long>> arrayTrimMultiAsync(K key, String path, long start, long end);
+
+    /**
+     * Clears value by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    RFuture<Boolean> clearAsync(K key);
+
+    /**
+     * Clears json containers by specified keys.
+     *
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    RFuture<Long> clearAsync(Set<K> keys);
+
+    /**
+     * Clears json container by specified keys and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    RFuture<Long> clearAsync(String path, Set<K> keys);
+
+    /**
+     * Increments the current value specified by key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return the updated value
+     */
+    <T extends Number> RFuture<T> incrementAndGetAsync(K key, String path, T delta);
+
+    /**
+     * Increments the current values specified by key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return list of updated value
+     */
+    <T extends Number> RFuture<List<T>> incrementAndGetMultiAsync(K key, String path, T delta);
+
+    /**
+     * Merges object into element by the specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to merge
+     */
+    RFuture<Void> mergeAsync(K key, String path, Object value);
+
+    /**
+     * Returns keys amount in JSON container by specified key
+     *
+     * @param key entry key
+     * @return keys amount
+     */
+    RFuture<Long> countKeysAsync(K key);
+
+    /**
+     * Returns keys amount in JSON container specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return keys amount
+     */
+    RFuture<Long> countKeysAsync(K key, String path);
+
+    /**
+     * Returns list of keys amount in JSON containers specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of keys amount
+     */
+    RFuture<List<Long>> countKeysMultiAsync(K key, String path);
+
+    /**
+     * Returns list of keys in JSON container by specified key
+     *
+     * @return list of keys
+     */
+    RFuture<List<String>> getKeysAsync(K key);
+
+    /**
+     * Returns list of keys in JSON container by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    RFuture<List<String>> getKeysAsync(K key, String path);
+
+    /**
+     * Returns list of keys in JSON containers by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    RFuture<List<List<String>>> getKeysMultiAsync(K key, String path);
+
+    /**
+     * Toggle boolean value by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return new boolean value
+     */
+    RFuture<Boolean> toggleAsync(K key, String path);
+
+    /**
+     * Toggle boolean values by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of boolean values
+     */
+    RFuture<List<Boolean>> toggleMultiAsync(K key, String path);
+
+    /**
+     * Returns type of value
+     *
+     * @return type of element
+     */
+    RFuture<JsonType> getTypeAsync(K key);
+
+    /**
+     * Returns type of element specified by key and JSONPath
+     *
+     * @param path JSON path
+     * @return type of element
+     */
+    RFuture<JsonType> getTypeAsync(K key, String path);
+
+    /**
+     * Deletes entry by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    RFuture<Boolean> deleteAsync(K key);
+
+    /**
+     * Deletes JSON elements specified by keys
+     *
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    RFuture<Long> deleteAsync(Set<K> keys);
+
+    /**
+     * Deletes JSON elements specified by keys and JSONPath
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    RFuture<Long> deleteAsync(String path, Set<K> keys);
+
+    /**
+     * Returns size of entry in bytes specified by key.
+     *
+     * @param key entry key
+     * @return entry size
+     */
+    RFuture<Long> sizeInMemoryAsync(K key);
+
+    /**
+     * Retrieves value by specified key.
+     *
+     * @param key entry key
+     * @return element
+     */
+    RFuture<V> getAsync(K key);
+
+    /**
+     * Retrieves values by specified keys.
+     *
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    RFuture<Map<K, V>> getAsync(Set<K> keys);
+
+    /**
+     * Retrieves values by specified keys and JSONPath.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    RFuture<Map<K, V>> getAsync(String path, Set<K> keys);
+
+    /**
+     * Retrieves entry value by specified key and removes it.
+     *
+     * @param key entry key
+     * @return element
+     */
+    RFuture<V> getAndDeleteAsync(K key);
+
+    /**
+     * Sets value only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    RFuture<Boolean> setIfAbsentAsync(K key, V value);
+
+    /**
+     * Sets value with defined duration only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    RFuture<Boolean> setIfAbsentAsync(K key, V value, Duration duration);
+
+    /**
+     * Sets value only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    RFuture<Boolean> setIfExistsAsync(K key, V value);
+
+    /**
+     * Sets <code>value</code> with expiration <code>duration</code> only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    RFuture<Boolean> setIfExistsAsync(K key, V value, Duration duration);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key only if serialized state of the current value equals
+     * to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    RFuture<Boolean> compareAndSetAsync(K key, V expect, V update);
+
+    /**
+     * Retrieves current value by specified key and replaces it with new value.
+     *
+     * @param key entry key
+     * @param newValue value to set
+     * @return previous value
+     */
+    RFuture<V> getAndSetAsync(K key, V newValue);
+
+    /**
+     * Retrieves current value by specified key and replaces it
+     * with value and defines expiration <code>duration</code>.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return previous value
+     */
+    RFuture<V> getAndSetAsync(K key, V value, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration duration for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param duration of object time to live interval
+     * @return value
+     */
+    RFuture<V> getAndExpireAsync(K key, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration date for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param time of exact object expiration moment
+     * @return value
+     */
+    RFuture<V> getAndExpireAsync(K key, Instant time);
+
+    /**
+     * Retrieves current value by specified key and clears expiration date set before.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @return value
+     */
+    RFuture<V> getAndClearExpireAsync(K key);
+
+    /**
+     * Stores value by specified key.
+     *
+     * @param key entry key
+     * @param value value to set
+     */
+    RFuture<Void> setAsync(K key, V value);
+
+    /**
+     * Stores values by specified keys.
+     *
+     * @param entries entries to store
+     */
+    RFuture<Void> setAsync(Map<K, V> entries);
+
+    /**
+     * Stores values by specified keys and JSONPath.
+     *
+     * @param path JSONPath
+     * @param entries entries to store
+     */
+    RFuture<Void> setAsync(String path, Map<K, V> entries);
+
+    /**
+     * Stores value by specified key with defined expiration duration.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     */
+    RFuture<Void> setAsync(K key, V value, Duration duration);
+
+    /**
+     * Stores values by specified keys with defined expiration duration.
+     *
+     * @param entries entries to store
+     * @param duration expiration duration
+     */
+    RFuture<Void> setAsync(Map<K, V> entries, Duration duration);
+
+    /**
+     * Sets value by specified key and keep existing TTL.
+     * <p>
+     * Requires <b>Redis 6.0.0 and higher.</b>
+     *
+     * @param value value to set
+     * @return void
+     */
+    RFuture<Void> setAndKeepTTLAsync(K key, V value);
+//
+//    /**
+//     * 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.SetObjectListener
+//     *
+//     * @param listener object event listener
+//     * @return listener id
+//     */
+//    RFuture<Integer> addListenerAsync(K key, ObjectListener listener);
+
+    /**
+     * Remaining time to live of map entry associated with a <code>key</code>.
+     *
+     * @param key - map key
+     * @return time in milliseconds
+     *          -2 if the key does not exist.
+     *          -1 if the key exists but has no associated expire.
+     */
+    RFuture<Long> remainTimeToLiveAsync(K key);
+
+    /**
+     * Returns <code>true</code> if this map contains map entry
+     * mapped by specified <code>key</code>, otherwise <code>false</code>
+     *
+     * @param key - map key
+     * @return <code>true</code> if this map contains map entry
+     *          mapped by specified <code>key</code>, otherwise <code>false</code>
+     */
+    RFuture<Boolean> containsKeyAsync(Object key);
+
+    /**
+     * Read all keys at once
+     *
+     * @return keys
+     */
+    RFuture<Set<K>> readAllKeySetAsync();
+
+    /**
+     * Returns entries amount in store
+     *
+     * @return entries amount
+     */
+    RFuture<Integer> sizeAsync();
+
+    /**
+     * Adds object event listener
+     *
+     * @see org.redisson.api.ExpiredObjectListener
+     * @see org.redisson.api.DeletedObjectListener
+     * @see org.redisson.api.listener.SetObjectListener
+     *
+     * @param listener - object event listener
+     * @return listener id
+     */
+    RFuture<Integer> addListenerAsync(ObjectListener listener);
+
+}
diff --git a/redisson/src/main/java/org/redisson/api/RJsonStoreReactive.java b/redisson/src/main/java/org/redisson/api/RJsonStoreReactive.java
new file mode 100644
index 000000000..4183e898c
--- /dev/null
+++ b/redisson/src/main/java/org/redisson/api/RJsonStoreReactive.java
@@ -0,0 +1,893 @@
+/**
+ * Copyright (c) 2013-2024 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;
+
+import org.redisson.codec.JsonCodec;
+import reactor.core.publisher.Mono;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * JSON Store which stores each entry as key and value. Both are POJO objects.
+ * Value is stored as JSON datatype in Redis.
+ * <p>
+ * The implementation is available in Redisson PRO only.
+ *
+ * @author Nikita Koksharov
+ *
+ * @param <K> the type of key
+ * @param <V> the type of value
+ *
+ */
+public interface RJsonStoreReactive<K, V> extends RExpirableReactive {
+
+    /**
+     * Gets value by specified key and JSONPath
+     *
+     * @param key   entry key
+     * @param codec entry value codec
+     * @param paths JSON paths
+     * @param <T>   the type of object
+     * @return entry value
+     */
+    <T> Mono<T> get(K key, JsonCodec codec, String... paths);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value entry value
+     * @return {@code true} if successful, or {@code false} if
+     *         value was already set
+     */
+    Mono<Boolean> setIfAbsent(K key, String path, Object value);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is non-empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value object
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    Mono<Boolean> setIfExists(K key, String path, Object value);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key and JSONPath, only if serialized state of
+     * the current value equals to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    Mono<Boolean> compareAndSet(K key, String path, Object expect, Object update);
+
+    /**
+     * Retrieves current value stored by specified key and JSONPath then
+     * replaces it with new value.
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param path JSON path
+     * @param newValue value to set
+     * @return previous value
+     */
+    <T> Mono<T> getAndSet(K key, JsonCodec codec, String path, Object newValue);
+
+    /**
+     * Stores value by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to set
+     */
+    Mono<Void> set(K key, String path, Object value);
+
+    /**
+     * Returns size of string data by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of string
+     */
+    Mono<Long> stringSize(K key, String path);
+
+    /**
+     * Returns list of string data size by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of string data sizes
+     */
+    Mono<List<Long>> stringSizeMulti(K key, String path);
+
+    /**
+     * Appends string data to element specified by specified key and JSONPath.
+     * Returns new size of string data.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return size of string data
+     */
+    Mono<Long> stringAppend(K key, String path, Object value);
+
+    /**
+     * Appends string data to elements specified by specified key and JSONPath.
+     * Returns new size of string data.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return list of string data sizes
+     */
+    Mono<List<Long>> stringAppendMulti(K key, String path, Object value);
+
+    /**
+     * Appends values to array by specified key and JSONPath.
+     * Returns new size of array.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return size of array
+     */
+    Mono<Long> arrayAppend(K key, String path, Object... values);
+
+    /**
+     * Appends values to arrays by specified key and JSONPath.
+     * Returns new size of arrays.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return list of arrays size
+     */
+    Mono<List<Long>> arrayAppendMulti(K key, String path, Object... values);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return index in array
+     */
+    Mono<Long> arrayIndex(K key, String path, Object value);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return list of index in arrays
+     */
+    Mono<List<Long>> arrayIndexMulti(K key, String path, Object value);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return index in array
+     */
+    Mono<Long> arrayIndex(K key, String path, Object value, Mono<Long> start, Mono<Long> end);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return list of index in arrays
+     */
+    Mono<List<Long>> arrayIndexMulti(K key, String path, Object value, Mono<Long> start, Mono<Long> end);
+
+    /**
+     * Inserts values into array by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return size of array
+     */
+    Mono<Long> arrayInsert(K key, String path, Mono<Long> index, Object... values);
+
+    /**
+     * Inserts values into arrays by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return list of arrays size
+     */
+    Mono<List<Long>> arrayInsertMulti(K key, String path, Mono<Long> index, Object... values);
+
+    /**
+     * Returns size of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of array
+     */
+    Mono<Long> arraySize(K key, String path);
+
+    /**
+     * Returns size of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of arrays size
+     */
+    Mono<List<Long>> arraySizeMulti(K key, String path);
+
+    /**
+     * Polls last element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return last element
+     *
+     * @param <T> the type of object
+     */
+    <T> Mono<T> arrayPollLast(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls last element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of last elements
+     *
+     * @param <T> the type of object
+     */
+    <T> Mono<List<T>> arrayPollLastMulti(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return first element
+     *
+     * @param <T> the type of object
+     */
+    <T> Mono<T> arrayPollFirst(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of first elements
+     *
+     * @param <T> the type of object
+     */
+    <T> Mono<List<T>> arrayPollFirstMulti(K key, JsonCodec codec, String path);
+
+    /**
+     * Pops element located at index of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return element
+     *
+     * @param <T> the type of object
+     */
+    <T> Mono<T> arrayPop(K key, JsonCodec codec, String path, Mono<Long> index);
+
+    /**
+     * Pops elements located at index of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return list of elements
+     *
+     * @param <T> the type of object
+     */
+    <T> Mono<List<T>> arrayPopMulti(K key, JsonCodec codec, String path, Mono<Long> index);
+
+    /**
+     * Trims array by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    Mono<Long> arrayTrim(K key, String path, Mono<Long> start, Mono<Long> end);
+
+    /**
+     * Trims arrays by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    Mono<List<Long>> arrayTrimMulti(K key, String path, Mono<Long> start, Mono<Long> end);
+
+    /**
+     * Clears value by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    Mono<Boolean> clear(K key);
+
+    /**
+     * Clears json containers by specified keys.
+     *
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    Mono<Long> clear(Mono<Set<K>> keys);
+
+    /**
+     * Clears json container by specified keys and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    Mono<Long> clear(String path, Mono<Set<K>> keys);
+
+    /**
+     * Increments the current value specified by key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return the updated value
+     */
+    <T extends Number> Mono<T> incrementAndGet(K key, String path, Mono<T> delta);
+
+    /**
+     * Increments the current values specified by key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return list of updated value
+     */
+    <T extends Number> Mono<List<T>> incrementAndGetMulti(K key, String path, Mono<T> delta);
+
+    /**
+     * Merges value into element by the specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to merge
+     */
+    Mono<Void> merge(K key, String path, Object value);
+
+    /**
+     * Returns keys amount in JSON container by specified key
+     *
+     * @param key entry key
+     * @return keys amount
+     */
+    Mono<Long> countKeys(K key);
+
+    /**
+     * Returns keys amount in JSON container specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return keys amount
+     */
+    Mono<Long> countKeys(K key, String path);
+
+    /**
+     * Returns list of keys amount in JSON containers specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of keys amount
+     */
+    Mono<List<Long>> countKeysMulti(K key, String path);
+
+    /**
+     * Returns list of keys in JSON container by specified key
+     *
+     * @return list of keys
+     */
+    Mono<List<String>> getKeys(K key);
+
+    /**
+     * Returns list of keys in JSON container by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    Mono<List<String>> getKeys(K key, String path);
+
+    /**
+     * Returns list of keys in JSON containers by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    List<Mono<List<String>>> getKeysMulti(K key, String path);
+
+    /**
+     * Toggle Mono<Boolean> value by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return new Mono<Boolean> value
+     */
+    Mono<Boolean> toggle(K key, String path);
+
+    /**
+     * Toggle Mono<Boolean> values by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of Mono<Boolean> values
+     */
+    List<Mono<Boolean>> toggleMulti(K key, String path);
+
+    /**
+     * Returns type of value
+     *
+     * @return type of element
+     */
+    Mono<JsonType> getType(K key);
+
+    /**
+     * Returns type of element specified by key and JSONPath
+     *
+     * @param path JSON path
+     * @return type of element
+     */
+    Mono<JsonType> getType(K key, String path);
+
+    /**
+     * Deletes entry by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    Mono<Boolean> delete(K key);
+
+    /**
+     * Deletes entries by specified keys
+     *
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    Mono<Long> delete(Mono<Set<K>> keys);
+
+    /**
+     * Deletes JSON elements specified by keys and JSONPath
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    Mono<Long> delete(String path, Mono<Set<K>> keys);
+
+    /**
+     * Returns size of entry in bytes specified by key.
+     *
+     * @param key entry key
+     * @return entry size
+     */
+    Mono<Long> sizeInMemory(K key);
+
+    /**
+     * Retrieves value by specified key.
+     *
+     * @param key entry key
+     * @return element
+     */
+    Mono<V> get(K key);
+
+    /**
+     * Retrieves values by specified keys.
+     *
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    Mono<Map<K, V>> get(Mono<Set<K>> keys);
+
+    /**
+     * Retrieves values by specified keys and JSONPath.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    Mono<Map<K, V>> get(String path, Mono<Set<K>> keys);
+
+    /**
+     * Retrieves entry value by specified key and removes it.
+     *
+     * @param key entry key
+     * @return element
+     */
+    Mono<V> getAndDelete(K key);
+
+    /**
+     * Sets value only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    Mono<Boolean> setIfAbsent(K key, V value);
+
+    /**
+     * Sets value with defined duration only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    Mono<Boolean> setIfAbsent(K key, V value, Duration duration);
+
+    /**
+     * Sets value only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    Mono<Boolean> setIfExists(K key, V value);
+
+    /**
+     * Sets <code>value</code> with expiration <code>duration</code> only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    Mono<Boolean> setIfExists(K key, V value, Duration duration);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key only if serialized state of the current value equals
+     * to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    Mono<Boolean> compareAndSet(K key, V expect, V update);
+
+    /**
+     * Retrieves current value by specified key and replaces it with new value.
+     *
+     * @param key entry key
+     * @param newValue value to set
+     * @return previous value
+     */
+    Mono<V> getAndSet(K key, V newValue);
+
+    /**
+     * Retrieves current value by specified key and replaces it
+     * with value and defines expiration <code>duration</code>.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return previous value
+     */
+    Mono<V> getAndSet(K key, V value, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration duration for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param duration of object time to live interval
+     * @return value
+     */
+    Mono<V> getAndExpire(K key, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration date for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param time of exact object expiration moment
+     * @return value
+     */
+    Mono<V> getAndExpire(K key, Instant time);
+
+    /**
+     * Retrieves current value by specified key and clears expiration date set before.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @return value
+     */
+    Mono<V> getAndClearExpire(K key);
+
+    /**
+     * Stores value by specified key.
+     *
+     * @param key entry key
+     * @param value value to set
+     */
+    Mono<Void> set(K key, V value);
+
+    /**
+     * Stores values by specified keys.
+     *
+     * @param entries entries to store
+     */
+    Mono<Void> set(Mono<Map<K, V>> entries);
+
+    /**
+     * Stores values by specified keys and JSONPath.
+     *
+     * @param path JSONPath
+     * @param entries entries to store
+     */
+    Mono<Void> set(String path, Mono<Map<K, V>> entries);
+
+    /**
+     * Stores value by specified key with defined expiration duration.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     */
+    Mono<Void> set(K key, V value, Duration duration);
+
+    /**
+     * Stores values by specified keys with defined expiration duration.
+     *
+     * @param entries entries to store
+     * @param duration expiration duration
+     */
+    Mono<Void> set(Mono<Map<K, V>> entries, Duration duration);
+
+    /**
+     * Sets value by specified key and keep existing TTL.
+     * <p>
+     * Requires <b>Redis 6.0.0 and higher.</b>
+     *
+     * @param value value to set
+     */
+    Mono<Void> setAndKeepTTL(K key, V value);
+
+    /**
+     * Adds object event listener
+     *
+     * @see ExpiredObjectListener
+     * @see DeletedObjectListener
+     * @see org.redisson.api.listener.SetObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    Mono<Integer> addListener(ObjectListener listener);
+
+    /**
+     * Remaining time to live of map entry associated with a <code>key</code>.
+     *
+     * @param key - map key
+     * @return time in milliseconds
+     *          -2 if the key does not exist.
+     *          -1 if the key exists but has no associated expire.
+     */
+    Mono<Long> remainTimeToLive(K key);
+
+    /**
+     * Returns key set of this map.
+     * Keys are loaded in batch. Batch size is <code>10</code>.
+     *
+     * @see #readAllKeySet()
+     *
+     * @return key set
+     */
+    Mono<Set<K>> keySet();
+
+    /**
+     * Returns key set of this map.
+     * Keys are loaded in batch. Batch size is defined by <code>count</code> param.
+     *
+     * @see #readAllKeySet()
+     *
+     * @param count - size of keys batch
+     * @return key set
+     */
+    Mono<Set<K>> keySet(int count);
+
+    /**
+     * Returns key set of this map.
+     * If <code>pattern</code> is not null then only keys match this pattern are loaded.
+     * Keys are loaded in batch. Batch size is defined by <code>count</code> param.
+     * <p>
+     * Use <code>org.redisson.client.codec.StringCodec</code> for Map keys.
+     * <p>
+     *
+     *  Supported glob-style patterns:
+     *  <p>
+     *    h?llo subscribes to hello, hallo and hxllo
+     *    <p>
+     *    h*llo subscribes to hllo and heeeello
+     *    <p>
+     *    h[ae]llo subscribes to hello and hallo, but not hillo
+     *
+     * @see #readAllKeySet()
+     *
+     * @param pattern - key pattern
+     * @param count - size of keys batch
+     * @return key set
+     */
+    Mono<Set<K>> keySet(String pattern, Mono<Integer> count);
+
+    /**
+     * Returns key set of this map.
+     * If <code>pattern</code> is not null then only keys match this pattern are loaded.
+     * <p>
+     * Use <code>org.redisson.client.codec.StringCodec</code> for Map keys.
+     * <p>
+     *
+     *  Supported glob-style patterns:
+     *  <p>
+     *    h?llo subscribes to hello, hallo and hxllo
+     *    <p>
+     *    h*llo subscribes to hllo and heeeello
+     *    <p>
+     *    h[ae]llo subscribes to hello and hallo, but not hillo
+     *
+     * @see #readAllKeySet()
+     *
+     * @param pattern - key pattern
+     * @return key set
+     */
+    Mono<Set<K>> keySet(String pattern);
+
+    /**
+     * Returns <code>true</code> if this map contains map entry
+     * mapped by specified <code>key</code>, otherwise <code>false</code>
+     *
+     * @param key - map key
+     * @return <code>true</code> if this map contains map entry
+     *          mapped by specified <code>key</code>, otherwise <code>false</code>
+     */
+    Mono<Boolean> containsKey(Object key);
+
+    /**
+     * Read all keys at once
+     *
+     * @return keys
+     */
+    Mono<Set<K>> readAllKeySet();
+
+    /**
+     * Returns entries amount in store
+     *
+     * @return entries amount
+     */
+    Mono<Integer> size();
+
+    /**
+     * Returns <code>RCountDownLatch</code> instance associated with key
+     *
+     * @param key - map key
+     * @return countdownlatch
+     */
+    RCountDownLatch getCountDownLatch(K key);
+
+    /**
+     * Returns <code>RPermitExpirableSemaphore</code> instance associated with key
+     *
+     * @param key - map key
+     * @return permitExpirableSemaphore
+     */
+    RPermitExpirableSemaphore getPermitExpirableSemaphore(K key);
+
+    /**
+     * Returns <code>RSemaphore</code> instance associated with key
+     *
+     * @param key - map key
+     * @return semaphore
+     */
+    RSemaphore getSemaphore(K key);
+
+    /**
+     * Returns <code>RLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return fairlock
+     */
+    RLock getFairLock(K key);
+
+    /**
+     * Returns <code>RReadWriteLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return readWriteLock
+     */
+    RReadWriteLock getReadWriteLock(K key);
+
+    /**
+     * Returns <code>RLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return lock
+     */
+    RLock getLock(K key);
+
+}
diff --git a/redisson/src/main/java/org/redisson/api/RJsonStoreRx.java b/redisson/src/main/java/org/redisson/api/RJsonStoreRx.java
new file mode 100644
index 000000000..44a6a5277
--- /dev/null
+++ b/redisson/src/main/java/org/redisson/api/RJsonStoreRx.java
@@ -0,0 +1,896 @@
+/**
+ * Copyright (c) 2013-2024 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;
+
+import io.reactivex.rxjava3.core.Completable;
+import io.reactivex.rxjava3.core.Maybe;
+import io.reactivex.rxjava3.core.Single;
+import org.redisson.codec.JsonCodec;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * JSON Store which stores each entry as key and value. Both are POJO objects.
+ * Value is stored as JSON datatype in Redis.
+ * <p>
+ * The implementation is available in Redisson PRO only.
+ *
+ * @author Nikita Koksharov
+ *
+ * @param <K> the type of key
+ * @param <V> the type of value
+ *
+ */
+public interface RJsonStoreRx<K, V> extends RExpirableRx {
+
+    /**
+     * Gets value by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param paths JSON paths
+     * @return entry value
+     *
+     * @param <T> the type of object
+     */
+    <T> Maybe<T> get(K key, JsonCodec codec, String... paths);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value entry value
+     * @return {@code true} if successful, or {@code false} if
+     *         value was already set
+     */
+    Single<Boolean> setIfAbsent(K key, String path, Object value);
+
+    /**
+     * Sets value by specified key and JSONPath only if previous value is non-empty.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value object
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    Single<Boolean> setIfExists(K key, String path, Object value);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key and JSONPath, only if serialized state of
+     * the current value equals to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    Single<Boolean> compareAndSet(K key, String path, Object expect, Object update);
+
+    /**
+     * Retrieves current value stored by specified key and JSONPath then
+     * replaces it with new value.
+     *
+     * @param key entry key
+     * @param codec entry value codec
+     * @param path JSON path
+     * @param newValue value to set
+     * @return previous value
+     */
+    <T> Maybe<T> getAndSet(K key, JsonCodec codec, String path, Object newValue);
+
+    /**
+     * Stores value by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to set
+     */
+    Completable set(K key, String path, Object value);
+
+    /**
+     * Returns size of string data by specified key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of string
+     */
+    Maybe<Long> stringSize(K key, String path);
+
+    /**
+     * Returns list of string data size by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of string data sizes
+     */
+    Single<List<Long>> stringSizeMulti(K key, String path);
+
+    /**
+     * Appends string data to element specified by specified key and JSONPath.
+     * Returns new size of string data.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return size of string data
+     */
+    Single<Long> stringAppend(K key, String path, Object value);
+
+    /**
+     * Appends string data to elements specified by specified key and JSONPath.
+     * Returns new size of string data.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value data
+     * @return list of string data sizes
+     */
+    Single<List<Long>> stringAppendMulti(K key, String path, Object value);
+
+    /**
+     * Appends values to array by specified key and JSONPath.
+     * Returns new size of array.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return size of array
+     */
+    Single<Long> arrayAppend(K key, String path, Object... values);
+
+    /**
+     * Appends values to arrays by specified key and JSONPath.
+     * Returns new size of arrays.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param values values to append
+     * @return list of arrays size
+     */
+    Single<List<Long>> arrayAppendMulti(K key, String path, Object... values);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return index in array
+     */
+    Single<Long> arrayIndex(K key, String path, Object value);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @return list of index in arrays
+     */
+    Single<List<Long>> arrayIndexMulti(K key, String path, Object value);
+
+    /**
+     * Returns index of object in array by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return index in array
+     */
+    Single<Long> arrayIndex(K key, String path, Object value, Single<Long> start, Single<Long> end);
+
+    /**
+     * Returns index of object in arrays by specified key and JSONPath
+     * in range between <code>start</code> (inclusive) and <code>end</code> (exclusive) indexes.
+     * -1 means object not found.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to search
+     * @param start start index, inclusive
+     * @param end end index, exclusive
+     * @return list of index in arrays
+     */
+    Single<List<Long>> arrayIndexMulti(K key, String path, Object value, Single<Long> start, Single<Long> end);
+
+    /**
+     * Inserts values into array by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return size of array
+     */
+    Single<Long> arrayInsert(K key, String path, Single<Long> index, Object... values);
+
+    /**
+     * Inserts values into arrays by specified key and JSONPath.
+     * Values are inserted at defined <code>index</code>.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param index array index at which values are inserted
+     * @param values values to insert
+     * @return list of arrays size
+     */
+    Single<List<Long>> arrayInsertMulti(K key, String path, Single<Long> index, Object... values);
+
+    /**
+     * Returns size of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return size of array
+     */
+    Single<Long> arraySize(K key, String path);
+
+    /**
+     * Returns size of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of arrays size
+     */
+    Single<List<Long>> arraySizeMulti(K key, String path);
+
+    /**
+     * Polls last element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return last element
+     *
+     * @param <T> the type of object
+     */
+    <T> Maybe<T> arrayPollLast(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls last element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of last elements
+     *
+     * @param <T> the type of object
+     */
+    <T> Single<List<T>> arrayPollLastMulti(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return first element
+     *
+     * @param <T> the type of object
+     */
+    <T> Maybe<T> arrayPollFirst(K key, JsonCodec codec, String path);
+
+    /**
+     * Polls first element of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @return list of first elements
+     *
+     * @param <T> the type of object
+     */
+    <T> Single<List<T>> arrayPollFirstMulti(K key, JsonCodec codec, String path);
+
+    /**
+     * Pops element located at index of array by specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return element
+     *
+     * @param <T> the type of object
+     */
+    <T> Maybe<T> arrayPop(K key, JsonCodec codec, String path, Single<Long> index);
+
+    /**
+     * Pops elements located at index of arrays by specified key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param codec object codec
+     * @param path JSON path
+     * @param index array index
+     * @return list of elements
+     *
+     * @param <T> the type of object
+     */
+    <T> Single<List<T>> arrayPopMulti(K key, JsonCodec codec, String path, Single<Long> index);
+
+    /**
+     * Trims array by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    Single<Long> arrayTrim(K key, String path, Single<Long> start, Single<Long> end);
+
+    /**
+     * Trims arrays by specified key and JSONPath in range
+     * between <code>start</code> (inclusive) and <code>end</code> (inclusive) indexes.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param start start index, inclusive
+     * @param end end index, inclusive
+     * @return length of array
+     */
+    Single<List<Long>> arrayTrimMulti(K key, String path, Single<Long> start, Single<Long> end);
+
+    /**
+     * Clears value by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    Single<Boolean> clear(K key);
+
+    /**
+     * Clears json containers by specified keys.
+     *
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    Single<Long> clear(Set<K> keys);
+
+    /**
+     * Clears json container by specified keys and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of cleared containers
+     */
+    Single<Long> clear(String path, Set<K> keys);
+
+    /**
+     * Increments the current value specified by key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return the updated value
+     */
+    <T extends Number> Maybe<T> incrementAndGet(K key, String path, Maybe<T> delta);
+
+    /**
+     * Increments the current values specified by key and JSONPath.
+     * Compatible only with enhanced syntax starting with '$' character.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param delta increment value
+     * @return list of updated value
+     */
+    <T extends Number> List<T> incrementAndGetMulti(K key, String path, Maybe<T> delta);
+
+    /**
+     * Merges value into element by the specified key and JSONPath.
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @param value value to merge
+     */
+    Completable merge(K key, String path, Object value);
+
+    /**
+     * Returns keys amount in JSON container by specified key
+     *
+     * @param key entry key
+     * @return keys amount
+     */
+    Maybe<Long> countKeys(K key);
+
+    /**
+     * Returns keys amount in JSON container specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return keys amount
+     */
+    Maybe<Long> countKeys(K key, String path);
+
+    /**
+     * Returns list of keys amount in JSON containers specified by key and JSONPath
+     *
+     * @param key entry key
+     * @param path JSON path
+     * @return list of keys amount
+     */
+    Single<List<Long>> countKeysMulti(K key, String path);
+
+    /**
+     * Returns list of keys in JSON container by specified key
+     *
+     * @return list of keys
+     */
+    Single<List<String>> getKeys(K key);
+
+    /**
+     * Returns list of keys in JSON container by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    Single<List<String>> getKeys(K key, String path);
+
+    /**
+     * Returns list of keys in JSON containers by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of keys
+     */
+    Single<List<List<String>>> getKeysMulti(K key, String path);
+
+    /**
+     * Toggle Single<Boolean> value by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return new Single<Boolean> value
+     */
+    Single<Boolean> toggle(K key, String path);
+
+    /**
+     * Toggle Single<Boolean> values by specified key and JSONPath
+     *
+     * @param path JSON path
+     * @return list of Single<Boolean> values
+     */
+    Single<List<Boolean>> toggleMulti(K key, String path);
+
+    /**
+     * Returns type of value
+     *
+     * @return type of element
+     */
+    Single<JsonType> getType(K key);
+
+    /**
+     * Returns type of element specified by key and JSONPath
+     *
+     * @param path JSON path
+     * @return type of element
+     */
+    Single<JsonType> getType(K key, String path);
+
+    /**
+     * Deletes entry by specified key
+     *
+     * @param key entry key
+     * @return {@code true} if successful, or {@code false} if
+     *         entry doesn't exist
+     */
+    Single<Boolean> delete(K key);
+
+    /**
+     * Deletes entries by specified keys
+     *
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    Single<Long> delete(Set<K> keys);
+
+    /**
+     * Deletes JSON elements specified by keys and JSONPath
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return number of deleted elements
+     */
+    Single<Long> delete(String path, Set<K> keys);
+
+    /**
+     * Returns size of entry in bytes specified by key.
+     *
+     * @param key entry key
+     * @return entry size
+     */
+    Single<Long> sizeInMemory(K key);
+
+    /**
+     * Retrieves value by specified key.
+     *
+     * @param key entry key
+     * @return element
+     */
+    Maybe<V> get(K key);
+
+    /**
+     * Retrieves values by specified keys.
+     *
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    Single<Map<K, V>> get(Set<K> keys);
+
+    /**
+     * Retrieves values by specified keys and JSONPath.
+     *
+     * @param path JSON path
+     * @param keys entry keys
+     * @return map with entries where value mapped by key
+     */
+    Single<Map<K, V>> get(String path, Set<K> keys);
+
+    /**
+     * Retrieves entry value by specified key and removes it.
+     *
+     * @param key entry key
+     * @return element
+     */
+    Maybe<V> getAndDelete(K key);
+
+    /**
+     * Sets value only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    Single<Boolean> setIfAbsent(K key, V value);
+
+    /**
+     * Sets value with defined duration only if entry doesn't exist.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element was already set
+     */
+    Single<Boolean> setIfAbsent(K key, V value, Duration duration);
+
+    /**
+     * Sets value only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    Single<Boolean> setIfExists(K key, V value);
+
+    /**
+     * Sets <code>value</code> with expiration <code>duration</code> only if entry already exists.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return {@code true} if successful, or {@code false} if
+     *         element wasn't set
+     */
+    Single<Boolean> setIfExists(K key, V value, Duration duration);
+
+    /**
+     * Atomically sets the value to the given updated value
+     * by specified key only if serialized state of the current value equals
+     * to serialized state of the expected value.
+     *
+     * @param key entry key
+     * @param expect the expected value
+     * @param update the new value
+     * @return {@code true} if successful; or {@code false} if the actual value
+     *         was not equal to the expected value.
+     */
+    Single<Boolean> compareAndSet(K key, V expect, V update);
+
+    /**
+     * Retrieves current value by specified key and replaces it with new value.
+     *
+     * @param key entry key
+     * @param newValue value to set
+     * @return previous value
+     */
+    Maybe<V> getAndSet(K key, V newValue);
+
+    /**
+     * Retrieves current value by specified key and replaces it
+     * with value and defines expiration <code>duration</code>.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     * @return previous value
+     */
+    Maybe<V> getAndSet(K key, V value, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration duration for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param duration of object time to live interval
+     * @return value
+     */
+    Maybe<V> getAndExpire(K key, Duration duration);
+
+    /**
+     * Retrieves current value by specified key and sets an expiration date for it.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @param time of exact object expiration moment
+     * @return value
+     */
+    Maybe<V> getAndExpire(K key, Instant time);
+
+    /**
+     * Retrieves current value by specified key and clears expiration date set before.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param key entry key
+     * @return value
+     */
+    Maybe<V> getAndClearExpire(K key);
+
+    /**
+     * Stores value by specified key.
+     *
+     * @param key entry key
+     * @param value value to set
+     */
+    Completable set(K key, V value);
+
+    /**
+     * Stores values by specified keys.
+     *
+     * @param entries entries to store
+     */
+    Completable set(Map<K, V> entries);
+
+    /**
+     * Stores values by specified keys and JSONPath.
+     *
+     * @param path JSONPath
+     * @param entries entries to store
+     */
+    Completable set(String path, Map<K, V> entries);
+
+    /**
+     * Stores value by specified key with defined expiration duration.
+     *
+     * @param key entry key
+     * @param value value to set
+     * @param duration expiration duration
+     */
+    Completable set(K key, V value, Duration duration);
+
+    /**
+     * Stores values by specified keys with defined expiration duration.
+     *
+     * @param entries entries to store
+     * @param duration expiration duration
+     */
+    Completable set(Map<K, V> entries, Duration duration);
+
+    /**
+     * Sets value by specified key and keep existing TTL.
+     * <p>
+     * Requires <b>Redis 6.0.0 and higher.</b>
+     *
+     * @param value value to set
+     */
+    Completable setAndKeepTTL(K key, V value);
+
+    /**
+     * Adds object event listener
+     *
+     * @see ExpiredObjectListener
+     * @see DeletedObjectListener
+     * @see org.redisson.api.listener.SetObjectListener
+     *
+     * @param listener object event listener
+     * @return listener id
+     */
+    Single<Integer> addListener(ObjectListener listener);
+
+    /**
+     * Remaining time to live of map entry associated with a <code>key</code>.
+     *
+     * @param key - map key
+     * @return time in milliseconds
+     *          -2 if the key does not exist.
+     *          -1 if the key exists but has no associated expire.
+     */
+    Single<Long> remainTimeToLive(K key);
+
+    /**
+     * Returns key set of this map.
+     * Keys are loaded in batch. Batch size is <code>10</code>.
+     *
+     * @see #readAllKeySet()
+     *
+     * @return key set
+     */
+    Set<K> keySet();
+
+    /**
+     * Returns key set of this map.
+     * Keys are loaded in batch. Batch size is defined by <code>count</code> param.
+     *
+     * @see #readAllKeySet()
+     *
+     * @param count - size of keys batch
+     * @return key set
+     */
+    Set<K> keySet(int count);
+
+    /**
+     * Returns key set of this map.
+     * If <code>pattern</code> is not null then only keys match this pattern are loaded.
+     * Keys are loaded in batch. Batch size is defined by <code>count</code> param.
+     * <p>
+     * Use <code>org.redisson.client.codec.StringCodec</code> for Map keys.
+     * <p>
+     *
+     *  Supported glob-style patterns:
+     *  <p>
+     *    h?llo subscribes to hello, hallo and hxllo
+     *    <p>
+     *    h*llo subscribes to hllo and heeeello
+     *    <p>
+     *    h[ae]llo subscribes to hello and hallo, but not hillo
+     *
+     * @see #readAllKeySet()
+     *
+     * @param pattern - key pattern
+     * @param count - size of keys batch
+     * @return key set
+     */
+    Set<K> keySet(String pattern, int count);
+
+    /**
+     * Returns key set of this map.
+     * If <code>pattern</code> is not null then only keys match this pattern are loaded.
+     * <p>
+     * Use <code>org.redisson.client.codec.StringCodec</code> for Map keys.
+     * <p>
+     *
+     *  Supported glob-style patterns:
+     *  <p>
+     *    h?llo subscribes to hello, hallo and hxllo
+     *    <p>
+     *    h*llo subscribes to hllo and heeeello
+     *    <p>
+     *    h[ae]llo subscribes to hello and hallo, but not hillo
+     *
+     * @see #readAllKeySet()
+     *
+     * @param pattern - key pattern
+     * @return key set
+     */
+    Set<K> keySet(String pattern);
+
+    /**
+     * Returns <code>true</code> if this map contains map entry
+     * mapped by specified <code>key</code>, otherwise <code>false</code>
+     *
+     * @param key - map key
+     * @return <code>true</code> if this map contains map entry
+     *          mapped by specified <code>key</code>, otherwise <code>false</code>
+     */
+    Single<Boolean> containsKey(Object key);
+
+    /**
+     * Read all keys at once
+     *
+     * @return keys
+     */
+    Set<K> readAllKeySet();
+
+    /**
+     * Returns entries amount in store
+     *
+     * @return entries amount
+     */
+    Single<Integer> size();
+
+    /**
+     * Returns <code>RCountDownLatch</code> instance associated with key
+     *
+     * @param key - map key
+     * @return countdownlatch
+     */
+    RCountDownLatch getCountDownLatch(K key);
+
+    /**
+     * Returns <code>RPermitExpirableSemaphore</code> instance associated with key
+     *
+     * @param key - map key
+     * @return permitExpirableSemaphore
+     */
+    RPermitExpirableSemaphore getPermitExpirableSemaphore(K key);
+
+    /**
+     * Returns <code>RSemaphore</code> instance associated with key
+     *
+     * @param key - map key
+     * @return semaphore
+     */
+    RSemaphore getSemaphore(K key);
+
+    /**
+     * Returns <code>RLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return fairlock
+     */
+    RLock getFairLock(K key);
+
+    /**
+     * Returns <code>RReadWriteLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return readWriteLock
+     */
+    RReadWriteLock getReadWriteLock(K key);
+
+    /**
+     * Returns <code>RLock</code> instance associated with key
+     *
+     * @param key - map key
+     * @return lock
+     */
+    RLock getLock(K key);
+
+}