Package org.redisson.rx

Class RedissonTransactionRx

org.redisson.rx.RedissonTransactionRx

All Implemented Interfaces:

RTransactionRx

public class RedissonTransactionRx
extends 
implements RTransactionRx

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
RedissonTransactionRx(CommandRxExecutor executorService, TransactionOptions options)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	commit()	Commits all changes made on this transaction.
<V> RBucketRx<V>	name)	Returns transactional object holder instance by name.
<V> RBucketRx<V>	name, Codec codec)	Returns transactional object holder instance by name using provided codec for object.
<K,V> RMapRx<K,V>	name)	Returns transactional map instance by name.
<K,V> RMapRx<K,V>	name, Codec codec)	Returns transactional map instance by name using provided codec for both map keys and values.
<K,V> RMapCacheRx<K,V>	name)	Returns transactional map-based cache instance by name.
<K,V> RMapCacheRx<K,V>	name, Codec codec)	Returns transactional map-based cache instance by name using provided codec for both cache keys and values.
<V> RSetRx<V>	name)	Returns transactional set instance by name.
<V> RSetRx<V>	name, Codec codec)	Returns transactional set instance by name using provided codec for set objects.
<V> RSetCacheRx<V>	name)	Returns transactional set-based cache instance by name.
<V> RSetCacheRx<V>	name, Codec codec)	Returns transactional set-based cache instance by name.
io.reactivex.rxjava3.core.Completable	rollback()	Rollback all changes made on this transaction.

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Detail

RedissonTransactionRx

public RedissonTransactionRx(CommandRxExecutor executorService,
                             TransactionOptions options)

Method Detail

getBucket

public <V>  name)

Description copied from interface: RTransactionRx

Returns transactional object holder instance by name.

Specified by:

getBucket in interface RTransactionRx

Type Parameters:

V - type of value

Parameters:

name - - name of object

Returns:

Bucket object

getBucket

public <V>  name,
                                  Codec codec)

Description copied from interface: RTransactionRx

Returns transactional object holder instance by name using provided codec for object.

Specified by:

getBucket in interface RTransactionRx

Type Parameters:

V - type of value

Parameters:

name - - name of object

codec - - codec for values

Returns:

Bucket object

getMap

public <K,V>  name)

Description copied from interface: RTransactionRx

Returns transactional map instance by name.

Specified by:

getMap in interface RTransactionRx

Type Parameters:

K - type of key

V - type of value

Parameters:

name - - name of object

Returns:

Map object

getMap

public <K,V>  name,
                                            Codec codec)

Description copied from interface: RTransactionRx

Returns transactional map instance by name using provided codec for both map keys and values.

Specified by:

getMap in interface RTransactionRx

Type Parameters:

K - type of key

V - type of value

Parameters:

name - - name of object

codec - - codec for keys and values

Returns:

Map object

getMapCache

public <K,V>  name,
                                                      Codec codec)

Description copied from interface: RTransactionRx

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 RTransactionRx.getMap(String, Codec).

Specified by:

getMapCache in interface RTransactionRx

Type Parameters:

K - type of key

V - type of value

Parameters:

name - - object name

codec - - codec for keys and values

Returns:

MapCache object

getMapCache

public <K,V>  name)

Description copied from interface: RTransactionRx

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 RTransactionRx.getMap(String).

Specified by:

getMapCache in interface RTransactionRx

Type Parameters:

K - type of key

V - type of value

Parameters:

name - - name of object

Returns:

MapCache object

getSet

public <V>  name)

Description copied from interface: RTransactionRx

Returns transactional set instance by name.

Specified by:

getSet in interface RTransactionRx

Type Parameters:

V - type of value

Parameters:

name - - name of object

Returns:

Set object

getSet

public <V>  name,
                            Codec codec)

Description copied from interface: RTransactionRx

Returns transactional set instance by name using provided codec for set objects.

Specified by:

getSet in interface RTransactionRx

Type Parameters:

V - type of value

Parameters:

name - - name of object

codec - - codec for values

Returns:

Set object

getSetCache

public <V>  name)

Description copied from interface: RTransactionRx

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 RTransactionRx.getSet(String).

Specified by:

getSetCache in interface RTransactionRx

Type Parameters:

V - type of value

Parameters:

name - - name of object

Returns:

SetCache object

getSetCache

public <V>  name,
                                      Codec codec)

Description copied from interface: RTransactionRx

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 RTransactionRx.getSet(String, Codec).

Specified by:

getSetCache in interface RTransactionRx

Type Parameters:

V - type of value

Parameters:

name - - name of object

codec - - codec for values

Returns:

SetCache object

commit

public io.reactivex.rxjava3.core.Completable commit()

Description copied from interface: RTransactionRx

Commits all changes made on this transaction.

Specified by:

commit in interface RTransactionRx

Returns:

void

rollback

public io.reactivex.rxjava3.core.Completable rollback()

Description copied from interface: RTransactionRx

Rollback all changes made on this transaction.

Specified by:

rollback in interface RTransactionRx

Returns:

void