From dad1b8c39402e533e0765dbe99e5e8c2fe7e88a5 Mon Sep 17 00:00:00 2001 From: Mike Hobbs Date: Thu, 10 Feb 2011 10:51:48 -0600 Subject: [PATCH] Connect.connect() now honors timeout value --- src/main/java/redis/clients/jedis/Connection.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/redis/clients/jedis/Connection.java b/src/main/java/redis/clients/jedis/Connection.java index c310cd6..4136fd3 100644 --- a/src/main/java/redis/clients/jedis/Connection.java +++ b/src/main/java/redis/clients/jedis/Connection.java @@ -1,6 +1,7 @@ package redis.clients.jedis; import java.io.IOException; +import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketException; import java.util.ArrayList; @@ -102,7 +103,8 @@ public class Connection { public void connect() { if (!isConnected()) { try { - socket = new Socket(host, port); + socket = new Socket(); + socket.connect(new InetSocketAddress(host, port), timeout); socket.setSoTimeout(timeout); outputStream = new RedisOutputStream(socket.getOutputStream()); inputStream = new RedisInputStream(socket.getInputStream());