[jbosscache-commits] JBoss Cache SVN: r7465 - core/trunk/src/main/java/org/jboss/cache/loader.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-01-14 10:05:13 -0500 (Wed, 14 Jan 2009)
New Revision: 7465

Modified:
   core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java
Log:
Set timeout before creating socket

Modified: core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java	2009-01-14 14:54:45 UTC (rev 7464)
+++ core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java	2009-01-14 15:05:13 UTC (rev 7465)
@@ -38,6 +38,7 @@
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.net.ConnectException;
+import java.net.InetSocketAddress;
 import java.net.Socket;
 import java.util.List;
 import java.util.Map;
@@ -396,8 +397,10 @@
    {
       try
       {
-         sock = new Socket(config.getHost(), config.getPort());
+         InetSocketAddress address = new InetSocketAddress(config.getHost(), config.getPort());
+         sock = new Socket();
          sock.setSoTimeout(config.getReadTimeout());
+         sock.connect(address, config.getReadTimeout());
          out = new ObjectOutputStream(new BufferedOutputStream(sock.getOutputStream()));
          out.flush();
          in = new ObjectInputStream(new BufferedInputStream(sock.getInputStream()));