Interface RedissonRxClient

  • All Known Implementing Classes:
    RedissonRx

    public interface RedissonRxClient
    Main Redisson interface for access to all redisson objects with RxJava2 interface.
    Author:
    Nikita Koksharov
    See Also:
    RedissonReactiveClient, RedissonClient
    • Method Summary

      All Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      RBatchRx createBatch()
      Return batch object which executes group of command in pipeline.
      RBatchRx createBatch​(BatchOptions options)
      Return batch object which executes group of command in pipeline.
      RTransactionRx createTransaction​(TransactionOptions options)
      Creates transaction with READ_COMMITTED isolation level.
      RAtomicDoubleRx  name)
      Returns "atomic double" instance by name.
      RAtomicLongRx  name)
      Returns "atomic long" instance by name.
      RBinaryStreamRx  name)
      Returns binary stream holder instance by name
      RBitSetRx  name)
      Returns bitSet instance by name.
      <V> RBlockingDequeRx<V>  name)
      Returns unbounded blocking deque instance by name.
      <V> RBlockingDequeRx<V>  name, Codec codec)
      Returns unbounded blocking deque instance by name using provided codec for deque objects.
      <V> RBlockingQueueRx<V>  name)
      Returns blocking queue instance by name.
      <V> RBlockingQueueRx<V>  name, Codec codec)
      Returns blocking queue instance by name using provided codec for queue objects.
      <V> RBucketRx<V>  name)
      Returns object holder instance by name
      <V> RBucketRx<V>  name, Codec codec)
      Returns object holder instance by name using provided codec for object.
      RBucketsRx getBuckets()
      Returns interface for mass operations with Bucket objects.
      RBucketsRx getBuckets​(Codec codec)
      Returns interface for mass operations with Bucket objects using provided codec for object.
      NodesGroup<ClusterNode> getClusterNodesGroup()
      Get Redis cluster nodes group for server operations
      Config getConfig()
      Allows to get configuration provided during Redisson instance creation.
      RCountDownLatchRx  name)
      Returns CountDownLatch instance by name.
      <V> RDequeRx<V>  name)
      Returns deque instance by name.
      <V> RDequeRx<V>  name, Codec codec)
      Returns deque instance by name using provided codec for deque objects.
      RLockRx  name)
      Returns Lock instance by name.
      <V> RGeoRx<V>  name)
      Returns geospatial items holder instance by name.
      <V> RGeoRx<V>  name, Codec codec)
      Returns geospatial items holder instance by name using provided codec for geospatial members.
      <V> RHyperLogLogRx<V>  name)
      Returns HyperLogLog instance by name.
      <V> RHyperLogLogRx<V>  name, Codec codec)
      Returns HyperLogLog instance by name using provided codec for hll objects.
      getId()
      Returns id of this Redisson instance
      RIdGeneratorRx  name)
      Returns id generator by name.
      RKeysRx getKeys()
      Returns keys operations.
      RLexSortedSetRx  name)
      Returns String based Redis Sorted Set instance by name All elements are inserted with the same score during addition, in order to force lexicographical ordering
      <V> RListRx<V>  name)
      Returns list instance by name.
      <V> RListRx<V>  name, Codec codec)
      Returns list instance by name using provided codec for list objects.
      <K,​V>
      RListMultimapRx<K,​V>
       name)
      Returns List based Multimap instance by name.
      <K,​V>
      RListMultimapRx<K,​V>
       name, Codec codec)
      Returns List based Multimap instance by name using provided codec for both map keys and values.
      <K,​V>
      RListMultimapCacheRx<K,​V>
       name)
      Returns List based Multimap cache instance by name.
      <K,​V>
      RListMultimapCacheRx<K,​V>
       name, Codec codec)
      Returns List based Multimap cache instance by name using provided codec for both map keys and values.
      RLockRx  name)
      Returns Lock instance by name.
      <K,​V>
      RMapRx<K,​V>
       name)
      Returns map instance by name.
      <K,​V>
      RMapRx<K,​V>
       name, MapOptions<K,​V> options)
      Returns map instance by name.
      <K,​V>
      RMapRx<K,​V>
       name, Codec codec)
      Returns map instance by name using provided codec for both map keys and values.
      <K,​V>
      RMapRx<K,​V>
       name, Codec codec, MapOptions<K,​V> options)
      Returns map instance by name using provided codec for both map keys and values.
      <K,​V>
      RMapCacheRx<K,​V>
       name)
      Returns map-based cache instance by name.
      <K,​V>
      RMapCacheRx<K,​V>
       name, MapOptions<K,​V> options)
      Returns map-based cache instance by name.
      <K,​V>
      RMapCacheRx<K,​V>
       name, Codec codec)
      Returns map-based cache instance by name using provided codec for both cache keys and values.
      <K,​V>
      RMapCacheRx<K,​V>
       name, Codec codec, MapOptions<K,​V> options)
      Returns map-based cache instance by name using provided codec for both cache keys and values.
      RLockRx getMultiLock​(RLock... locks)
      Returns MultiLock instance associated with specified locks
      NodesGroup<Node> getNodesGroup()
      Get Redis nodes group for server operations
      RPatternTopicRx  pattern)
      Returns topic instance satisfies by pattern name.
      RPatternTopicRx  pattern, Codec codec)
      Returns topic instance satisfies by pattern name using provided codec for messages.
      RPermitExpirableSemaphoreRx  name)
      Returns semaphore instance by name.
      <V> RQueueRx<V>  name)
      Returns queue instance by name.
      <V> RQueueRx<V>  name, Codec codec)
      Returns queue instance by name using provided codec for queue objects.
      RRateLimiterRx  name)
      Returns rate limiter instance by name
      RReadWriteLockRx  name)
      Returns ReadWriteLock instance by name.
      RLockRx getRedLock​(RLock... locks)
      Deprecated.
      RReliableTopicRx  name)
      Returns reliable topic instance by name.
      RReliableTopicRx  name, Codec codec)
      Returns reliable topic instance by name using provided codec for messages.
      RRemoteService getRemoteService()
      Returns object for remote operations prefixed with the default name (redisson_remote_service)
      RRemoteService  name)
      Returns object for remote operations prefixed with the specified name
      RRemoteService  name, Codec codec)
      Returns object for remote operations prefixed with the specified name and uses provided codec for method arguments and result.
      RRemoteService getRemoteService​(Codec codec)
      Returns object for remote operations prefixed with the default name (redisson_remote_service) and uses provided codec for method arguments and result.
      <V> RRingBufferRx<V>  name)
      Returns RingBuffer based queue.
      <V> RRingBufferRx<V>  name, Codec codec)
      Returns RingBuffer based queue.
      <V> RScoredSortedSetRx<V>  name)
      Returns Redis Sorted Set instance by name.
      <V> RScoredSortedSetRx<V>  name, Codec codec)
      Returns Redis Sorted Set instance by name using provided codec for sorted set objects.
      RScriptRx getScript()
      Returns script operations object
      RScriptRx getScript​(Codec codec)
      Returns script operations object using provided codec.
      RSemaphoreRx  name)
      Returns semaphore instance by name
      <V> RSetRx<V>  name)
      Returns set instance by name.
      <V> RSetRx<V>  name, Codec codec)
      Returns set instance by name using provided codec for set objects.
      <V> RSetCacheRx<V>  name)
      Returns set-based cache instance by name.
      <V> RSetCacheRx<V>  name, Codec codec)
      Returns set-based cache instance by name.
      <K,​V>
      RSetMultimapRx<K,​V>
       name)
      Returns Set based Multimap instance by name.
      <K,​V>
      RSetMultimapRx<K,​V>
       name, Codec codec)
      Returns Set based Multimap instance by name using provided codec for both map keys and values.
      <K,​V>
      RSetMultimapCacheRx<K,​V>
       name)
      Returns Set based Multimap cache instance by name.
      <K,​V>
      RSetMultimapCacheRx<K,​V>
       name, Codec codec)
      Returns Set based Multimap cache instance by name using provided codec for both map keys and values.
      RLockRx  name)
      Returns Spin lock instance by name.
      RLockRx  name, LockOptions.BackOff backOff)
      Returns Spin lock instance by name with specified back off options.
      <K,​V>
      RStreamRx<K,​V>
       name)
      Returns stream instance by name
      <K,​V>
      RStreamRx<K,​V>
       name, Codec codec)
      Returns stream instance by name using provided codec for entries.
      <V> RTimeSeriesRx<V>  name)
      Returns time-series instance by name
      <V> RTimeSeriesRx<V>  name, Codec codec)
      Returns time-series instance by name using provided codec for values.
      RTopicRx  name)
      Returns topic instance by name.
      RTopicRx  name, Codec codec)
      Returns topic instance by name using provided codec for messages.
      <V> RTransferQueueRx<V>  name)
      Returns transfer queue instance by name.
      <V> RTransferQueueRx<V>  name, Codec codec)
      Returns transfer queue instance by name using provided codec for queue objects.
      boolean isShutdown()
      Returns true if this Redisson instance has been shut down.
      boolean isShuttingDown()
      Returns true if this Redisson instance was started to be shutdown or was shutdown isShutdown() already.
      void shutdown()
      Shuts down Redisson instance NOT Redis server
    • Method Detail

      • getTimeSeries

        <V>  name)
        Returns time-series instance by name
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of instance
        Returns:
        RTimeSeries object
      • getTimeSeries

        <V>  name,
                                           Codec codec)
        Returns time-series instance by name using provided codec for values.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of instance
        codec - - codec for values
        Returns:
        RTimeSeries object
      • getStream

        <K,​V>  name)
        Returns stream instance by name

        Requires Redis 5.0.0 and higher.

        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - of stream
        Returns:
        RStream object
      • getStream

        <K,​V>  name,
                                                   Codec codec)
        Returns stream instance by name using provided codec for entries.

        Requires Redis 5.0.0 and higher.

        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of stream
        codec - - codec for entry
        Returns:
        RStream object
      • getGeo

        <V>  name)
        Returns geospatial items holder instance by name.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        Geo object
      • getGeo

        <V>  name,
                             Codec codec)
        Returns geospatial items holder instance by name using provided codec for geospatial members.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        codec - - codec for value
        Returns:
        Geo object
      • getRateLimiter

         name)
        Returns rate limiter instance by name
        Parameters:
        name - of rate limiter
        Returns:
        RateLimiter object
      • getBinaryStream

         name)
        Returns binary stream holder instance by name
        Parameters:
        name - of binary stream
        Returns:
        BinaryStream object
      • getSemaphore

         name)
        Returns semaphore instance by name
        Parameters:
        name - - name of object
        Returns:
        Semaphore object
      • getPermitExpirableSemaphore

         name)
        Returns semaphore instance by name. Supports lease time parameter for each acquired permit.
        Parameters:
        name - - name of object
        Returns:
        PermitExpirableSemaphore object
      • getReadWriteLock

         name)
        Returns ReadWriteLock instance by name.

        To increase reliability during failover, all operations wait for propagation to all Redis slaves.

        Parameters:
        name - - name of object
        Returns:
        Lock object
      • getFairLock

         name)
        Returns Lock instance by name.

        Implements a fair locking so it guarantees an acquire order by threads.

        To increase reliability during failover, all operations wait for propagation to all Redis slaves.

        Parameters:
        name - - name of object
        Returns:
        Lock object
      • getLock

         name)
        Returns Lock instance by name.

        Implements a non-fair locking so doesn't guarantees an acquire order by threads.

        To increase reliability during failover, all operations wait for propagation to all Redis slaves.

        Parameters:
        name - - name of object
        Returns:
        Lock object
      • getSpinLock

         name)
        Returns Spin lock instance by name.

        Implements a non-fair locking so doesn't guarantees an acquire order by threads.

        Lock doesn't use a pub/sub mechanism

        Parameters:
        name - - name of object
        Returns:
        Lock object
      • getSpinLock

         name,
                            LockOptions.BackOff backOff)
        Returns Spin lock instance by name with specified back off options.

        Implements a non-fair locking so doesn't guarantees an acquire order by threads.

        Lock doesn't use a pub/sub mechanism

        Parameters:
        name - - name of object
        Returns:
        Lock object
      • getMultiLock

        RLockRx getMultiLock​(RLock... locks)
        Returns MultiLock instance associated with specified locks
        Parameters:
        locks - - collection of locks
        Returns:
        MultiLock object
      • getRedLock

        RLockRx getRedLock​(RLock... locks)
        Deprecated.
      • getCountDownLatch

         name)
        Returns CountDownLatch instance by name.
        Parameters:
        name - - name of object
        Returns:
        CountDownLatch object
      • getSetCache

        <V>  name)
        Returns 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 values
        Parameters:
        name - - name of object
        Returns:
        SetCache object
      • getSetCache

        <V>  name,
                                       Codec codec)
        Returns 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 values
        Parameters:
        name - - name of object
        codec - - codec for values
        Returns:
        SetCache object
      • getMapCache

        <K,​V>  name,
                                                       Codec codec)
        Returns 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 keys
        V - type of values
        Parameters:
        name - - name of object
        codec - - codec for values
        Returns:
        MapCache object
      • getMapCache

        <K,​V>  name,
                                                       Codec codec,
                                                       MapOptions<K,​V> options)
        Returns 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, MapOptions).

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

        <K,​V>  name)
        Returns 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 keys
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        MapCache object
      • getMapCache

        <K,​V>  name,
                                                       MapOptions<K,​V> options)
        Returns 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, MapOptions).

        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        options - - map options
        Returns:
        MapCache object
      • getBucket

        <V>  name)
        Returns object holder instance by name
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        Bucket object
      • getBucket

        <V>  name,
                                   Codec codec)
        Returns object holder instance by name using provided codec for object.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        codec - - codec for value
        Returns:
        Bucket object
      • getBuckets

        RBucketsRx getBuckets()
        Returns interface for mass operations with Bucket objects.
        Returns:
        Buckets
      • getBuckets

        RBucketsRx getBuckets​(Codec codec)
        Returns interface for mass operations with Bucket objects using provided codec for object.
        Parameters:
        codec - - codec for bucket objects
        Returns:
        Buckets
      • getHyperLogLog

        <V>  name)
        Returns HyperLogLog instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        HyperLogLog object
      • getHyperLogLog

        <V>  name,
                                             Codec codec)
        Returns HyperLogLog instance by name using provided codec for hll objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        codec - - codec of values
        Returns:
        HyperLogLog object
      • getIdGenerator

         name)
        Returns id generator by name.
        Parameters:
        name - - name of object
        Returns:
        IdGenerator object
      • getList

        <V>  name)
        Returns list instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        List object
      • getList

        <V>  name,
                               Codec codec)
        Returns list instance by name using provided codec for list objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        codec - - codec for values
        Returns:
        List object
      • getListMultimap

        <K,​V>  name)
        Returns List based Multimap instance by name.
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        ListMultimap object
      • getListMultimap

        <K,​V>  name,
                                                               Codec codec)
        Returns List based Multimap 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:
        RListMultimapReactive object
      • getListMultimapCache

        <K,​V>  name)
        Returns List based Multimap cache instance by name. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular list multimap getListMultimap(String).
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        RListMultimapCacheRx object
      • getListMultimapCache

        <K,​V>  name,
                                                                         Codec codec)
        Returns List based Multimap cache instance by name using provided codec for both map keys and values. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular list multimap getListMultimap(String, Codec).
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        codec - - codec for keys and values
        Returns:
        RListMultimapCacheRx object
      • getSetMultimap

        <K,​V>  name)
        Returns Set based Multimap instance by name.
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        SetMultimap object
      • getSetMultimap

        <K,​V>  name,
                                                             Codec codec)
        Returns Set based Multimap 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:
        SetMultimap object
      • getSetMultimapCache

        <K,​V>  name)
        Returns Set based Multimap cache instance by name. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular set multimap getSetMultimap(String).
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        RSetMultimapCacheRx object
      • getSetMultimapCache

        <K,​V>  name,
                                                                       Codec codec)
        Returns Set based Multimap cache instance by name using provided codec for both map keys and values. Supports key eviction by specifying a time to live. If eviction is not required then it's better to use regular set multimap getSetMultimap(String, Codec).
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        codec - - codec for keys and values
        Returns:
        RSetMultimapCacheRx object
      • getMap

        <K,​V>  name)
        Returns map instance by name.
        Type Parameters:
        K - type of keys
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        Map object
      • getMap

        <K,​V>  name,
                                             MapOptions<K,​V> options)
        Returns map instance by name.
        Type Parameters:
        K - type of key
        V - type of value
        Parameters:
        name - - name of object
        options - - map options
        Returns:
        Map object
      • getMap

        <K,​V>  name,
                                             Codec codec)
        Returns map instance by name using provided codec for both map keys and values.
        Type Parameters:
        K - type of keys
        V - type of values
        Parameters:
        name - - name of object
        codec - - codec for keys and values
        Returns:
        Map object
      • getMap

        <K,​V>  name,
                                             Codec codec,
                                             MapOptions<K,​V> options)
        Returns 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
        options - - map options
        Returns:
        Map object
      • getSet

        <V>  name)
        Returns set instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        Set object
      • getSet

        <V>  name,
                             Codec codec)
        Returns set instance by name using provided codec for set objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of set
        codec - - codec for values
        Returns:
        Set object
      • getScoredSortedSet

        <V>  name)
        Returns Redis Sorted Set instance by name. This sorted set sorts objects by object score.
        Type Parameters:
        V - type of values
        Parameters:
        name - of scored sorted set
        Returns:
        ScoredSortedSet object
      • getScoredSortedSet

        <V>  name,
                                                     Codec codec)
        Returns Redis Sorted Set instance by name using provided codec for sorted set objects. This sorted set sorts objects by object score.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of scored sorted set
        codec - - codec for values
        Returns:
        ScoredSortedSet object
      • getLexSortedSet

         name)
        Returns String based Redis Sorted Set instance by name All elements are inserted with the same score during addition, in order to force lexicographical ordering
        Parameters:
        name - - name of object
        Returns:
        LexSortedSet object
      • getTopic

         name)
        Returns topic instance by name.
        Parameters:
        name - - name of object
        Returns:
        Topic object
      • getTopic

         name,
                          Codec codec)
        Returns topic instance by name using provided codec for messages.
        Parameters:
        name - - name of object
        codec - - codec for message
        Returns:
        Topic object
      • getReliableTopic

         name)
        Returns reliable topic instance by name.

        Dedicated Redis connection is allocated per instance (subscriber) of this object. Messages are delivered to all listeners attached to the same Redis setup.

        Requires Redis 5.0.0 and higher.

        Parameters:
        name - - name of object
        Returns:
        ReliableTopic object
      • getReliableTopic

         name,
                                          Codec codec)
        Returns reliable topic instance by name using provided codec for messages.

        Dedicated Redis connection is allocated per instance (subscriber) of this object. Messages are delivered to all listeners attached to the same Redis setup.

        Requires Redis 5.0.0 and higher.

        Parameters:
        name - - name of object
        codec - - codec for message
        Returns:
        ReliableTopic object
      • getPatternTopic

         pattern)
        Returns topic instance satisfies by pattern name. Supported glob-style patterns: h?llo subscribes to hello, hallo and hxllo h*llo subscribes to hllo and heeeello h[ae]llo subscribes to hello and hallo, but not hillo
        Parameters:
        pattern - of the topic
        Returns:
        PatternTopic object
      • getPatternTopic

         pattern,
                                        Codec codec)
        Returns topic instance satisfies by pattern name using provided codec for messages. Supported glob-style patterns: h?llo subscribes to hello, hallo and hxllo h*llo subscribes to hllo and heeeello h[ae]llo subscribes to hello and hallo, but not hillo
        Parameters:
        pattern - of the topic
        codec - - codec for message
        Returns:
        PatternTopic object
      • getQueue

        <V>  name)
        Returns queue instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        Queue object
      • getQueue

        <V>  name,
                                 Codec codec)
        Returns queue instance by name using provided codec for queue objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        codec - - codec for values
        Returns:
        Queue object
      • getRingBuffer

        <V>  name)
        Returns RingBuffer based queue.
        Type Parameters:
        V - value type
        Parameters:
        name - - name of object
        Returns:
        RingBuffer object
      • getRingBuffer

        <V>  name,
                                           Codec codec)
        Returns RingBuffer based queue.
        Type Parameters:
        V - value type
        Parameters:
        name - - name of object
        codec - - codec for values
        Returns:
        RingBuffer object
      • getBlockingQueue

        <V>  name)
        Returns blocking queue instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        BlockingQueue object
      • getBlockingQueue

        <V>  name,
                                                 Codec codec)
        Returns blocking queue instance by name using provided codec for queue objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        codec - - code for values
        Returns:
        BlockingQueue object
      • getBlockingDeque

        <V>  name)
        Returns unbounded blocking deque instance by name.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        BlockingDeque object
      • getBlockingDeque

        <V>  name,
                                                 Codec codec)
        Returns unbounded blocking deque instance by name using provided codec for deque objects.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        codec - - deque objects codec
        Returns:
        BlockingDeque object
      • getTransferQueue

        <V>  name)
        Returns transfer queue instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        TransferQueue object
      • getTransferQueue

        <V>  name,
                                                 Codec codec)
        Returns transfer queue instance by name using provided codec for queue objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        codec - - code for values
        Returns:
        TransferQueue object
      • getDeque

        <V>  name)
        Returns deque instance by name.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        Returns:
        Deque object
      • getDeque

        <V>  name,
                                 Codec codec)
        Returns deque instance by name using provided codec for deque objects.
        Type Parameters:
        V - type of values
        Parameters:
        name - - name of object
        codec - - coded for values
        Returns:
        Deque object
      • getAtomicLong

         name)
        Returns "atomic long" instance by name.
        Parameters:
        name - of the "atomic long"
        Returns:
        AtomicLong object
      • getAtomicDouble

         name)
        Returns "atomic double" instance by name.
        Parameters:
        name - of the "atomic double"
        Returns:
        AtomicLong object
      • getRemoteService

        RRemoteService getRemoteService()
        Returns object for remote operations prefixed with the default name (redisson_remote_service)
        Returns:
        RemoteService object
      • getRemoteService

        RRemoteService getRemoteService​(Codec codec)
        Returns object for remote operations prefixed with the default name (redisson_remote_service) and uses provided codec for method arguments and result.
        Parameters:
        codec - - codec for response and request
        Returns:
        RemoteService object
      • getRemoteService

         name)
        Returns object for remote operations prefixed with the specified name
        Parameters:
        name - - the name used as the Redis key prefix for the services
        Returns:
        RemoteService object
      • getRemoteService

         name,
                                        Codec codec)
        Returns object for remote operations prefixed with the specified name and uses provided codec for method arguments and result.
        Parameters:
        name - - the name used as the Redis key prefix for the services
        codec - - codec for response and request
        Returns:
        RemoteService object
      • getBitSet

         name)
        Returns bitSet instance by name.
        Parameters:
        name - - name of object
        Returns:
        BitSet object
      • getScript

        RScriptRx getScript()
        Returns script operations object
        Returns:
        Script object
      • getScript

        RScriptRx getScript​(Codec codec)
        Returns script operations object using provided codec.
        Parameters:
        codec - - codec for params and result
        Returns:
        Script object
      • createTransaction

        RTransactionRx createTransaction​(TransactionOptions options)
        Creates transaction with READ_COMMITTED isolation level.
        Parameters:
        options - - transaction configuration
        Returns:
        Transaction object
      • createBatch

        RBatchRx createBatch​(BatchOptions options)
        Return batch object which executes group of command in pipeline. See
        Parameters:
        options - - batch configuration
        Returns:
        Batch object
      • createBatch

        RBatchRx createBatch()
        Return batch object which executes group of command in pipeline. See
        Returns:
        Batch object
      • getKeys

        RKeysRx getKeys()
        Returns keys operations. Each of Redis/Redisson object associated with own key
        Returns:
        Keys object
      • shutdown

        void shutdown()
        Shuts down Redisson instance NOT Redis server
      • getConfig

        Config getConfig()
        Allows to get configuration provided during Redisson instance creation. Further changes on this object not affect Redisson instance.
        Returns:
        Config object
      • getNodesGroup

        NodesGroup<Node> getNodesGroup()
        Get Redis nodes group for server operations
        Returns:
        NodesGroup object
      • getClusterNodesGroup

        NodesGroup<ClusterNode> getClusterNodesGroup()
        Get Redis cluster nodes group for server operations
        Returns:
        NodesGroup object
      • isShutdown

        boolean isShutdown()
        Returns true if this Redisson instance has been shut down.
        Returns:
        true if this Redisson instance has been shut down otherwise false
      • isShuttingDown

        boolean isShuttingDown()
        Returns true if this Redisson instance was started to be shutdown or was shutdown isShutdown() already.
        Returns:
        true if this Redisson instance was started to be shutdown or was shutdown isShutdown() already otherwise false
      • getId

         getId()
        Returns id of this Redisson instance
        Returns:
        id