Package org.redisson.transaction

Class RedissonTransactionalBuckets

org.redisson.RedissonBuckets

org.redisson.transaction.RedissonTransactionalBuckets

All Implemented Interfaces:

RBuckets, RBucketsAsync

public class RedissonTransactionalBuckets
extends RedissonBuckets

Author:

Nikita Koksharov

Field Summary

Fields inherited from class org.redisson.RedissonBuckets

codec, commandExecutor

Constructor Summary

Constructors

Constructor	Description
RedissonTransactionalBuckets(Codec codec, CommandAsyncExecutor commandExecutor, long timeout, <TransactionalOperation> operations, executed, transactionId)
RedissonTransactionalBuckets(CommandAsyncExecutor commandExecutor, long timeout, <TransactionalOperation> operations, executed, transactionId)

Method Summary

Modifier and Type	Method	Description
protected void	checkState()
protected <R> void	executeLocked(RPromise<R> promise, runnable, <> keys)
<V> <,V>>	... keys)	Returns Redis object mapped by key.
>	<,?> buckets)	Saves objects mapped by Redis key.
>	<,?> buckets)	Try to save objects mapped by Redis key.

Methods inherited from class org.redisson.RedissonBuckets

get, set, trySet

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Detail

RedissonTransactionalBuckets

public RedissonTransactionalBuckets(CommandAsyncExecutor commandExecutor,
                                    long timeout,
                                    <TransactionalOperation> operations,
                                     executed,
                                     transactionId)

RedissonTransactionalBuckets

public RedissonTransactionalBuckets(Codec codec,
                                    CommandAsyncExecutor commandExecutor,
                                    long timeout,
                                    <TransactionalOperation> operations,
                                     executed,
                                     transactionId)

Method Detail

getAsync

public <V> <,V>> getAsync(... keys)

Description copied from interface: RBucketsAsync

Returns Redis object mapped by key. Result Map is not contains key-value entry for null values.

Specified by:

getAsync in interface RBucketsAsync

Overrides:

getAsync in class RedissonBuckets

Type Parameters:

V - type of value

Parameters:

keys - - keys

Returns:

Map with name of bucket as key and bucket as value

setAsync

public > setAsync(<,?> buckets)

Description copied from interface: RBucketsAsync

Saves objects mapped by Redis key.

Specified by:

setAsync in interface RBucketsAsync

Overrides:

setAsync in class RedissonBuckets

Parameters:

buckets - - map of buckets

Returns:

void

trySetAsync

public > trySetAsync(<,?> buckets)

Description copied from interface: RBucketsAsync

Try to save objects mapped by Redis key. If at least one of them is already exist then don't set none of them.

Specified by:

trySetAsync in interface RBucketsAsync

Overrides:

trySetAsync in class RedissonBuckets

Parameters:

buckets - - map of buckets

Returns:

true if object has been set otherwise false

executeLocked

protected <R> void executeLocked(RPromise<R> promise,
                                  runnable,
                                 <> keys)

checkState

protected void checkState()