Package org.redisson.api

Interface RTransactionReactive

public interface RTransactionReactive
Reactive interface for transaction object allows to execute transactions over Redisson objects. Uses locks for write operations and maintains data modification operations list till the commit/rollback operation.

Transaction isolation level: READ_COMMITTED

  • Method Details

    • getBucket

      <V> RBucketReactive<V> getBucket(String name)
      Returns transactional object holder instance by name.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      Bucket object

    • getBucket

      <V> RBucketReactive<V> getBucket(String name, Codec codec)
      Returns transactional object holder instance by name using provided codec for object.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for values
      Returns:
      Bucket object

    • getMap

      <K, V> RMapReactive<K,V> getMap(String name)
      Returns transactional map instance by name.
      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      Map object

    • getMap

      <K, V> RMapReactive<K,V> getMap(String name, Codec codec)
      Returns transactional map instance by name using provided codec for both map keys and values.
      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for keys and values
      Returns:
      Map object

    • getSet

      <V> RSetReactive<V> getSet(String name)
      Returns transactional set instance by name.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      Set object

    • getSet

      <V> RSetReactive<V> getSet(String name, Codec codec)
      Returns transactional set instance by name using provided codec for set objects.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for values
      Returns:
      Set object

    • getSetCache

      <V> RSetCacheReactive<V> getSetCache(String name)
      Returns transactional set-based cache instance by name. Supports value eviction with a given TTL value.

      If eviction is not required then it's better to use regular map getSet(String).

      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      SetCache object

    • getSetCache

      <V> RSetCacheReactive<V> getSetCache(String name, Codec codec)
      Returns transactional set-based cache instance by name. Supports value eviction with a given TTL value.

      If eviction is not required then it's better to use regular map getSet(String, Codec).

      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for values
      Returns:
      SetCache object

    • getMapCache

      <K, V> RMapCacheReactive<K,V> getMapCache(String name)
      Returns transactional map-based cache instance by name. Supports entry eviction with a given MaxIdleTime and TTL settings.

      If eviction is not required then it's better to use regular map getMap(String).

      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      MapCache object

    • getMapCache

      <K, V> RMapCacheReactive<K,V> getMapCache(String name, Codec codec)
      Returns transactional map-based cache instance by name using provided codec for both cache keys and values. Supports entry eviction with a given MaxIdleTime and TTL settings.

      If eviction is not required then it's better to use regular map getMap(String, Codec).

      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - object name
      codec - - codec for keys and values
      Returns:
      MapCache object

    • commit

      reactor.core.publisher.Mono<Void> commit()
      Commits all changes made on this transaction.
      Returns:
      void

    • rollback

      reactor.core.publisher.Mono<Void> rollback()
      Rollback all changes made on this transaction.
      Returns:
      void