|
|
@ -82,12 +82,12 @@ import io.netty.util.concurrent.Future;
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public class RedissonReactive implements RedissonReactiveClient {
|
|
|
|
public class RedissonReactive implements RedissonReactiveClient {
|
|
|
|
|
|
|
|
|
|
|
|
private final EvictionScheduler evictionScheduler;
|
|
|
|
protected final EvictionScheduler evictionScheduler;
|
|
|
|
private final CommandReactiveService commandExecutor;
|
|
|
|
protected final CommandReactiveService commandExecutor;
|
|
|
|
private final ConnectionManager connectionManager;
|
|
|
|
protected final ConnectionManager connectionManager;
|
|
|
|
private final Config config;
|
|
|
|
protected final Config config;
|
|
|
|
|
|
|
|
|
|
|
|
RedissonReactive(Config config) {
|
|
|
|
protected RedissonReactive(Config config) {
|
|
|
|
this.config = config;
|
|
|
|
this.config = config;
|
|
|
|
Config configCopy = new Config(config);
|
|
|
|
Config configCopy = new Config(config);
|
|
|
|
if (configCopy.getMasterSlaveServersConfig() != null) {
|
|
|
|
if (configCopy.getMasterSlaveServersConfig() != null) {
|
|
|
|