diff --git a/redisson/src/main/java/org/redisson/client/RedisClient.java b/redisson/src/main/java/org/redisson/client/RedisClient.java index 5cdfbd0ae..d5cc83245 100644 --- a/redisson/src/main/java/org/redisson/client/RedisClient.java +++ b/redisson/src/main/java/org/redisson/client/RedisClient.java @@ -86,6 +86,10 @@ public class RedisClient { public RedisClient(Timer timer, EventLoopGroup group, String host, int port) { this(timer, group, NioSocketChannel.class, host, port, 10000, 10000); } + + public RedisClient(String host, int port, int connectTimeout, int commandTimeout) { + this(new HashedWheelTimer(), new NioEventLoopGroup(), NioSocketChannel.class, host, port, connectTimeout, commandTimeout); + } public RedisClient(final Timer timer, EventLoopGroup group, Class socketChannelClass, String host, int port, int connectTimeout, int commandTimeout) { diff --git a/redisson/src/test/java/org/redisson/BaseTest.java b/redisson/src/test/java/org/redisson/BaseTest.java index a209ac02e..b4b34e394 100644 --- a/redisson/src/test/java/org/redisson/BaseTest.java +++ b/redisson/src/test/java/org/redisson/BaseTest.java @@ -69,7 +69,10 @@ public abstract class BaseTest { // config.setCodec(new MsgPackJacksonCodec()); // config.useSentinelServers().setMasterName("mymaster").addSentinelAddress("127.0.0.1:26379", "127.0.0.1:26389"); // config.useClusterServers().addNodeAddress("127.0.0.1:7004", "127.0.0.1:7001", "127.0.0.1:7000"); - config.useSingleServer().setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort()); + config.useSingleServer() + .setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort()) + .setConnectTimeout(1000000) + .setTimeout(1000000); // .setPassword("mypass1"); // config.useMasterSlaveConnection() // .setMasterAddress("127.0.0.1:6379") diff --git a/redisson/src/test/java/org/redisson/RedisClientTest.java b/redisson/src/test/java/org/redisson/RedisClientTest.java index e259e5e1e..9128b83e9 100644 --- a/redisson/src/test/java/org/redisson/RedisClientTest.java +++ b/redisson/src/test/java/org/redisson/RedisClientTest.java @@ -116,7 +116,9 @@ public class RedisClientTest { @Test public void test() throws InterruptedException { - RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort()); + RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerInstance().getRedisServerBindAddress(), + RedisRunner.getDefaultRedisServerInstance().getRedisServerPort(), + 1000000, 1000000); final RedisConnection conn = c.connect(); conn.sync(StringCodec.INSTANCE, RedisCommands.SET, "test", 0);