code cleanup

pull/395/head
Nikita 9 years ago
parent e061d1c7d7
commit ba18a3c5a7

@ -98,6 +98,7 @@ public class RedisConnection implements RedisCommands {
}
public <R> R await(Future<R> cmd) {
// TODO change connectTimeout to timeout
if (!cmd.awaitUninterruptibly(redisClient.getTimeout(), TimeUnit.MILLISECONDS)) {
Promise<R> promise = (Promise<R>)cmd;
RedisTimeoutException ex = new RedisTimeoutException("Command execution timeout for " + redisClient.getAddr());

@ -35,7 +35,6 @@ import org.redisson.ReadMode;
import org.redisson.client.BaseRedisPubSubListener;
import org.redisson.client.RedisClient;
import org.redisson.client.RedisConnection;
import org.redisson.client.RedisConnectionException;
import org.redisson.client.RedisNodeNotFoundException;
import org.redisson.client.RedisPubSubConnection;
import org.redisson.client.RedisPubSubListener;

Loading…
Cancel
Save