diff --git a/redisson/src/main/java/org/redisson/client/RedisConnection.java b/redisson/src/main/java/org/redisson/client/RedisConnection.java index e94c4e270..da53ef421 100644 --- a/redisson/src/main/java/org/redisson/client/RedisConnection.java +++ b/redisson/src/main/java/org/redisson/client/RedisConnection.java @@ -180,7 +180,7 @@ public class RedisConnection implements RedisCommands { } public RFuture async(RedisCommand command, Object... params) { - return async(null, command, params); + return async(-1, command, params); } public RFuture async(long timeout, RedisCommand command, Object... params) { @@ -255,7 +255,7 @@ public class RedisConnection implements RedisCommands { if (command != null && command.isBlockingCommand()) { channel.close(); } else { - RFuture f = async(redisClient.getConfig().getCommandTimeout(), RedisCommands.QUIT); + RFuture f = async(RedisCommands.QUIT); f.onComplete((res, e) -> { channel.close(); }); diff --git a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java index 793a120d4..2617ccaae 100755 --- a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -543,7 +543,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { return; } - RFuture r = connection.async(config.getTimeout(), RedisCommands.PING); + RFuture r = connection.async(RedisCommands.PING); r.onComplete((resp, exc) -> { if (exc != null) { result.tryFailure(exc);