io.lettuce.core.failover

Class StatefulRedisMultiDbPubSubConnectionImpl<K,V>

java.lang.Object

io.lettuce.core.failover.StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

io.lettuce.core.failover.StatefulRedisMultiDbPubSubConnectionImpl<K,V>

All Implemented Interfaces:

StatefulConnection<K,V>, StatefulRedisConnection<K,V>, BaseRedisMultiDbConnection, StatefulRedisMultiDbConnection<K,V>, StatefulRedisMultiDbPubSubConnection<K,V>, AsyncCloseable, StatefulRedisPubSubConnection<K,V>, AutoCloseable

@Experimental
public class StatefulRedisMultiDbPubSubConnectionImpl<K,V>
extends StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>
implements StatefulRedisMultiDbPubSubConnection<K,V>

Since:

7.4

Author:

Ali Takavci

Field Summary

Fields inherited from class io.lettuce.core.failover.StatefulRedisMultiDbConnectionImpl

async, codec, connectionFactory, connectionStateListeners, current, databases, healthStatusManager, parser, pushListeners, reactive, sync

Constructor Summary

Constructors

Constructor and Description
StatefulRedisMultiDbPubSubConnectionImpl(Map<RedisURI,RedisDatabase<StatefulRedisPubSubConnection<K,V>>> connections, ClientResources resources, RedisCodec<K,V> codec, Supplier<JsonParser> parser, io.lettuce.core.failover.DatabaseConnectionFactory<StatefulRedisPubSubConnection<K,V>,K,V> connectionFactory, HealthStatusManager healthStatusManager)

Method Summary

Modifier and Type	Method and Description
void	addListener(RedisPubSubListener<K,V> listener) Add a new listener.
RedisPubSubAsyncCommands<K,V>	async() Returns the RedisAsyncCommands API for the current connection.
void	moveSubscriptions(RedisDatabase<StatefulRedisPubSubConnection<K,V>> fromDb, RedisDatabase<StatefulRedisPubSubConnection<K,V>> toDb)
protected RedisPubSubAsyncCommandsImpl<K,V>	newRedisAsyncCommandsImpl() Create a new instance of RedisAsyncCommandsImpl.
protected RedisPubSubReactiveCommandsImpl<K,V>	newRedisReactiveCommandsImpl() Create a new instance of RedisReactiveCommandsImpl.
protected RedisPubSubCommands<K,V>	newRedisSyncCommandsImpl() Create a new instance of RedisCommands.
RedisPubSubReactiveCommands<K,V>	reactive() Returns the RedisReactiveCommands API for the current connection.
void	removeListener(RedisPubSubListener<K,V> listener) Remove an existing listener.
void	switchToDatabase(RedisURI redisURI) Switch to a different database.
RedisPubSubCommands<K,V>	sync() Returns the RedisCommands API for the current connection.

Methods inherited from class io.lettuce.core.failover.StatefulRedisMultiDbConnectionImpl

addDatabase, addDatabase, addListener, addListener, close, closeAsync, dispatch, dispatch, doByExclusiveLock, doBySharedLock, flushCommands, getCircuitBreaker, getCodec, getCurrentEndpoint, getEndpoints, getOptions, getResources, getTimeout, isHealthy, isMulti, isOpen, removeDatabase, removeListener, removeListener, setAutoFlushCommands, setTimeout, syncHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.lettuce.core.api.StatefulRedisConnection

addListener, isMulti, removeListener

Methods inherited from interface io.lettuce.core.api.StatefulConnection

addListener, close, closeAsync, dispatch, dispatch, flushCommands, getCodec, getOptions, getResources, getTimeout, isOpen, removeListener, setAutoFlushCommands, setTimeout

Methods inherited from interface io.lettuce.core.failover.api.BaseRedisMultiDbConnection

addDatabase, addDatabase, getCircuitBreaker, getCurrentEndpoint, getEndpoints, isHealthy, removeDatabase

Constructor Detail

StatefulRedisMultiDbPubSubConnectionImpl

public StatefulRedisMultiDbPubSubConnectionImpl(Map<RedisURI,RedisDatabase<StatefulRedisPubSubConnection<K,V>>> connections,
                                                ClientResources resources,
                                                RedisCodec<K,V> codec,
                                                Supplier<JsonParser> parser,
                                                io.lettuce.core.failover.DatabaseConnectionFactory<StatefulRedisPubSubConnection<K,V>,K,V> connectionFactory,
                                                HealthStatusManager healthStatusManager)

Method Detail

addListener

public void addListener(RedisPubSubListener<K,V> listener)

Description copied from interface: StatefulRedisPubSubConnection

Add a new listener.

Specified by:

addListener in interface StatefulRedisPubSubConnection<K,V>

Parameters:

listener - the listener, must not be null.

removeListener

public void removeListener(RedisPubSubListener<K,V> listener)

Description copied from interface: StatefulRedisPubSubConnection

Remove an existing listener.

Specified by:

removeListener in interface StatefulRedisPubSubConnection<K,V>

Parameters:

listener - the listener, must not be null.

async

public RedisPubSubAsyncCommands<K,V> async()

Description copied from interface: StatefulRedisConnection

Returns the RedisAsyncCommands API for the current connection. Does not create a new connection.

Specified by:

async in interface StatefulRedisConnection<K,V>

Specified by:

async in interface StatefulRedisPubSubConnection<K,V>

Overrides:

async in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Returns:

the asynchronous API for the underlying connection.

newRedisAsyncCommandsImpl

protected RedisPubSubAsyncCommandsImpl<K,V> newRedisAsyncCommandsImpl()

Description copied from class: StatefulRedisMultiDbConnectionImpl

Create a new instance of RedisAsyncCommandsImpl. Can be overriden to extend.

Overrides:

newRedisAsyncCommandsImpl in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Returns:

a new instance

sync

public RedisPubSubCommands<K,V> sync()

Description copied from interface: StatefulRedisConnection

Returns the RedisCommands API for the current connection. Does not create a new connection.

Specified by:

sync in interface StatefulRedisConnection<K,V>

Specified by:

sync in interface StatefulRedisPubSubConnection<K,V>

Overrides:

sync in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Returns:

the synchronous API for the underlying connection.

newRedisSyncCommandsImpl

protected RedisPubSubCommands<K,V> newRedisSyncCommandsImpl()

Description copied from class: StatefulRedisMultiDbConnectionImpl

Create a new instance of RedisCommands. Can be overriden to extend.

Overrides:

newRedisSyncCommandsImpl in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Returns:

a new instance

reactive

public RedisPubSubReactiveCommands<K,V> reactive()

Description copied from interface: StatefulRedisConnection

Returns the RedisReactiveCommands API for the current connection. Does not create a new connection.

Specified by:

reactive in interface StatefulRedisConnection<K,V>

Specified by:

reactive in interface StatefulRedisPubSubConnection<K,V>

Overrides:

reactive in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Returns:

the reactive API for the underlying connection.

newRedisReactiveCommandsImpl

protected RedisPubSubReactiveCommandsImpl<K,V> newRedisReactiveCommandsImpl()

Description copied from class: StatefulRedisMultiDbConnectionImpl

Create a new instance of RedisReactiveCommandsImpl. Can be overriden to extend.

Overrides:

newRedisReactiveCommandsImpl in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Returns:

a new instance

switchToDatabase

public void switchToDatabase(RedisURI redisURI)

Description copied from interface: BaseRedisMultiDbConnection

Switch to a different database.

Specified by:

switchToDatabase in interface BaseRedisMultiDbConnection

Overrides:

switchToDatabase in class StatefulRedisMultiDbConnectionImpl<StatefulRedisPubSubConnection<K,V>,K,V>

Parameters:

redisURI - the Redis URI of the database to switch to, must not be null

moveSubscriptions

public void moveSubscriptions(RedisDatabase<StatefulRedisPubSubConnection<K,V>> fromDb,
                              RedisDatabase<StatefulRedisPubSubConnection<K,V>> toDb)