svn commit: r614449 - in /webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse: SynapseConstants.java config/SynapseConfigUtils.java

[indika]

Author: indika
Date: Wed Jan 23 00:11:09 2008
New Revision: 614449

URL: http://svn.apache.org/viewvc?rev=614449&view=rev
Log:
add method to get connection read timeout and connection timeout from system 
property

Modified:
    
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
    
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/config/SynapseConfigUtils.java

Modified: 
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
URL: 
http://svn.apache.org/viewvc/webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java?rev=614449&r1=614448&r2=614449&view=diff
==============================================================================
--- 
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
 (original)
+++ 
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
 Wed Jan 23 00:11:09 2008
@@ -237,4 +237,14 @@
     /** Root for relative path */
     public static final String RESOLVE_ROOT = "resolve.root";
 
+    /* URL connection read timeout and connection timeout */
+
+    public static final int DEFAULT_READTIMEOUT = 100000;
+
+    public static final int DEFAULT_CONNECTTIMEOUT = 20000;
+
+    public static final String READTIMEOUT = "Connection.ReadTimeout";
+
+    public static final String CONNECTTIMEOUT = "Connection.ConnectTimeout";
+
 }

Modified: 
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/config/SynapseConfigUtils.java
URL: 
http://svn.apache.org/viewvc/webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/config/SynapseConfigUtils.java?rev=614449&r1=614448&r2=614449&view=diff
==============================================================================
--- 
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/config/SynapseConfigUtils.java
 (original)
+++ 
webservices/synapse/branches/1.1.1/modules/core/src/main/java/org/apache/synapse/config/SynapseConfigUtils.java
 Wed Jan 23 00:11:09 2008
@@ -186,8 +186,8 @@
             return null;
         }
         URLConnection conn = url.openConnection();
-        conn.setReadTimeout(10000);
-        conn.setConnectTimeout(2000);
+        conn.setReadTimeout(getReadTimeout());
+        conn.setConnectTimeout(getConnectionTimeout());
         conn.setRequestProperty("Connection", "close"); // if http is being 
used
         InputStream urlInStream = conn.getInputStream();
 
@@ -225,8 +225,8 @@
                 url = new URL("file:" + path);
             }
             URLConnection conn = url.openConnection();
-            conn.setReadTimeout(100000);
-            conn.setConnectTimeout(20000);
+            conn.setReadTimeout(getReadTimeout());
+            conn.setConnectTimeout(getConnectionTimeout());
             conn.setRequestProperty("Connection", "close"); // if http is 
being used
             InputStream urlInStream = conn.getInputStream();
             return new InputSource(urlInStream);
@@ -236,6 +236,32 @@
             handleException("Error reading at URI ' " + uri + " ' ", e);
         }
         return null;
+    }
+
+    private static int getReadTimeout() {
+        //getting  read timeout
+        String readTO = System.getProperty(SynapseConstants.READTIMEOUT);
+        int readTimeout = SynapseConstants.DEFAULT_READTIMEOUT;
+        if (readTO != null && !"".equals(readTO)) {
+            try {
+                readTimeout = Integer.parseInt(readTO);
+            } catch (NumberFormatException ignored) {
+            }
+        }
+        return readTimeout;
+    }
+
+    private static int getConnectionTimeout() {
+        //getting  connection timeout
+        String connectionTO = 
System.getProperty(SynapseConstants.CONNECTTIMEOUT);
+        int connectionTimeout = SynapseConstants.DEFAULT_CONNECTTIMEOUT;
+        if (connectionTO != null && !"".equals(connectionTO)) {
+            try {
+                connectionTimeout = Integer.parseInt(connectionTO);
+            } catch (NumberFormatException ignored) {
+            }
+        }
+        return connectionTimeout;
     }
 
     private static void handleException(String msg, Exception e) {



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]