Package org.redisson.reactive

Class RedissonTransactionReactive

org.redisson.reactive.RedissonTransactionReactive

All Implemented Interfaces:

RTransactionReactive

public class RedissonTransactionReactive
extends 
implements RTransactionReactive

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
RedissonTransactionReactive(CommandReactiveExecutor executorService, TransactionOptions options)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<>	commit()	Commits all changes made on this transaction.
<V> RBucketReactive<V>	name)	Returns transactional object holder instance by name.
<V> RBucketReactive<V>	name, Codec codec)	Returns transactional object holder instance by name using provided codec for object.
<K,V> RMapReactive<K,V>	name)	Returns transactional map instance by name.
<K,V> RMapReactive<K,V>	name, Codec codec)	Returns transactional map instance by name using provided codec for both map keys and values.
<K,V> RMapCacheReactive<K,V>	name)	Returns transactional map-based cache instance by name.
<K,V> RMapCacheReactive<K,V>	name, Codec codec)	Returns transactional map-based cache instance by name using provided codec for both cache keys and values.
<V> RSetReactive<V>	name)	Returns transactional set instance by name.
<V> RSetReactive<V>	name, Codec codec)	Returns transactional set instance by name using provided codec for set objects.
<V> RSetCacheReactive<V>	name)	Returns transactional set-based cache instance by name.
<V> RSetCacheReactive<V>	name, Codec codec)	Returns transactional set-based cache instance by name.
reactor.core.publisher.Mono<>	rollback()	Rollback all changes made on this transaction.

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Detail

RedissonTransactionReactive

public RedissonTransactionReactive(CommandReactiveExecutor executorService,
                                   TransactionOptions options)

Method Detail

getBucket

public <V>  name)

Description copied from interface: RTransactionReactive

Returns transactional object holder instance by name.

Specified by:

getBucket in interface RTransactionReactive

Type Parameters:

V - type of value

Parameters:

name - - name of object

Returns:

Bucket object

getBucket

public <V>  name,
                                        Codec codec)

Description copied from interface: RTransactionReactive

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

Specified by:

getBucket in interface RTransactionReactive

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: RTransactionReactive

Returns transactional map instance by name.

Specified by:

getMap in interface RTransactionReactive

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: RTransactionReactive

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

Specified by:

getMap in interface RTransactionReactive

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: RTransactionReactive

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

Specified by:

getMapCache in interface RTransactionReactive

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: RTransactionReactive

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

Specified by:

getMapCache in interface RTransactionReactive

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: RTransactionReactive

Returns transactional set instance by name.

Specified by:

getSet in interface RTransactionReactive

Type Parameters:

V - type of value

Parameters:

name - - name of object

Returns:

Set object

getSet

public <V>  name,
                                  Codec codec)

Description copied from interface: RTransactionReactive

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

Specified by:

getSet in interface RTransactionReactive

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: RTransactionReactive

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

Specified by:

getSetCache in interface RTransactionReactive

Type Parameters:

V - type of value

Parameters:

name - - name of object

Returns:

SetCache object

getSetCache

public <V>  name,
                                            Codec codec)

Description copied from interface: RTransactionReactive

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

Specified by:

getSetCache in interface RTransactionReactive

Type Parameters:

V - type of value

Parameters:

name - - name of object

codec - - codec for values

Returns:

SetCache object

commit

public reactor.core.publisher.Mono<> commit()

Description copied from interface: RTransactionReactive

Commits all changes made on this transaction.

Specified by:

commit in interface RTransactionReactive

Returns:

void

rollback

public reactor.core.publisher.Mono<> rollback()

Description copied from interface: RTransactionReactive

Rollback all changes made on this transaction.

Specified by:

rollback in interface RTransactionReactive

Returns:

void