svn commit: r831631 - /openejb/trunk/openejb3/server/openejb-client/src/main/java/org/apache/openejb/client/HttpConnectionFactory.java

[dblevins]

Author: dblevins
Date: Sun Nov  1 01:09:07 2009
New Revision: 831631

URL: http://svn.apache.org/viewvc?rev=831631&view=rev
Log:
OPENEJB-1100: EJB Clients using http can set connectTimeout and readTimeout

Modified:
    
openejb/trunk/openejb3/server/openejb-client/src/main/java/org/apache/openejb/client/HttpConnectionFactory.java

Modified: 
openejb/trunk/openejb3/server/openejb-client/src/main/java/org/apache/openejb/client/HttpConnectionFactory.java
URL: 
http://svn.apache.org/viewvc/openejb/trunk/openejb3/server/openejb-client/src/main/java/org/apache/openejb/client/HttpConnectionFactory.java?rev=831631&r1=831630&r2=831631&view=diff
==============================================================================
--- 
openejb/trunk/openejb3/server/openejb-client/src/main/java/org/apache/openejb/client/HttpConnectionFactory.java
 (original)
+++ 
openejb/trunk/openejb3/server/openejb-client/src/main/java/org/apache/openejb/client/HttpConnectionFactory.java
 Sun Nov  1 01:09:07 2009
@@ -23,8 +23,8 @@
 import java.net.HttpURLConnection;
 import java.net.URI;
 import java.net.URL;
-import java.net.NoRouteToHostException;
-import java.util.Properties;
+import java.net.URISyntaxException;
+import java.util.Map;
 
 /**
  * @version $Revision$ $Date$
@@ -45,8 +45,25 @@
         public HttpConnection(URI uri) throws IOException {
             this.uri = uri;
             URL url = uri.toURL();
+
+            Map<String, String> params;
+            try {
+                params = MulticastConnectionFactory.URIs.parseParamters(uri);
+            } catch (URISyntaxException e) {
+                throw new IllegalArgumentException("Invalid multicast uri " + 
uri.toString(), e);
+            }
+
             httpURLConnection = (HttpURLConnection)url.openConnection();
             httpURLConnection.setDoOutput(true);
+
+            if (params.containsKey("connectTimeout")) {
+                
httpURLConnection.setConnectTimeout(Integer.parseInt(params.get("connectTimeout")));
+            }
+
+            if (params.containsKey("readTimeout")) {
+                
httpURLConnection.setReadTimeout(Integer.parseInt(params.get("readTimeout")));
+            }
+
             httpURLConnection.connect();
         }