[jboss-svn-commits] JBL Code SVN: r27111 - in labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http: configurators and 1 other directory.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Jun 24 07:16:09 EDT 2009
Author: tfennelly
Date: 2009-06-24 07:16:09 -0400 (Wed, 24 Jun 2009)
New Revision: 27111
Added:
labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/configurators/Connection.java
Modified:
labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/HttpClientFactory.java
Log:
https://jira.jboss.org/jira/browse/JBESB-2635
Move HTTP Connection configuration code in HttpClientFactory to a Configurator
Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/HttpClientFactory.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/HttpClientFactory.java 2009-06-24 10:25:36 UTC (rev 27110)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/HttpClientFactory.java 2009-06-24 11:16:09 UTC (rev 27111)
@@ -21,13 +21,13 @@
import org.jboss.soa.esb.ConfigurationException;
import org.jboss.soa.esb.http.configurators.HttpProtocol;
+import org.jboss.soa.esb.http.configurators.Connection;
import org.jboss.soa.esb.util.ClassUtil;
import org.jboss.internal.soa.esb.assertion.AssertArgument;
import org.jboss.internal.soa.esb.util.StreamUtils;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpConnectionManager;
import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
-import org.apache.commons.httpclient.params.HttpConnectionManagerParams;
import java.util.Properties;
import java.io.IOException;
@@ -45,6 +45,7 @@
public static final String TARGET_HOST_URL = "target-host-url";
/**
* Max total connections.
+ * @deprecated
*/
public static final String MAX_TOTAL_CONNECTIONS = "max-total-connections";
@@ -59,19 +60,7 @@
public static HttpClient createHttpClient(Properties properties) throws ConfigurationException {
AssertArgument.isNotNull(properties, "properties");
- final HttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager() ;
- final String maxTotalConnections = properties.getProperty(MAX_TOTAL_CONNECTIONS) ;
- if (maxTotalConnections != null) {
- final HttpConnectionManagerParams params = new HttpConnectionManagerParams() ;
- try {
- params.setMaxTotalConnections(Integer.parseInt(maxTotalConnections)) ;
- } catch (final NumberFormatException nfe) {
- throw new ConfigurationException("Invalid " + MAX_TOTAL_CONNECTIONS + " property: " + maxTotalConnections) ;
- }
- connectionManager.setParams(params) ;
- }
-
- HttpClient httpClient = new HttpClient(connectionManager);
+ HttpClient httpClient = new HttpClient();
String fileConfig = (String) properties.remove("file");
String[] configurators;
@@ -83,6 +72,10 @@
}
}
+ // Apply the mandatory Configurators...
+ new Connection().configure(httpClient, properties);
+
+ // Apply the optional (configured) Configurators...
configurators = properties.getProperty("configurators", HttpProtocol.class.getName()).split(",");
for(String configuratorClass : configurators) {
Configurator configurator = createConfigurator(configuratorClass.trim());
Copied: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/configurators/Connection.java (from rev 27107, labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/configurators/HttpProtocol.java)
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/configurators/Connection.java (rev 0)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/configurators/Connection.java 2009-06-24 11:16:09 UTC (rev 27111)
@@ -0,0 +1,87 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and others contributors as indicated
+ * by the @authors tag. All rights reserved.
+ * See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU Lesser General Public License, v. 2.1.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
+ * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License,
+ * v.2.1 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+ * MA 02110-1301, USA.
+ *
+ * (C) 2005-2006, JBoss Inc.
+ */
+package org.jboss.soa.esb.http.configurators;
+
+import org.apache.commons.httpclient.HttpClient;
+import org.apache.commons.httpclient.ProxyHost;
+import org.apache.commons.httpclient.HttpConnectionManager;
+import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
+import org.apache.commons.httpclient.params.HttpConnectionManagerParams;
+import org.apache.commons.httpclient.contrib.ssl.StrictSSLProtocolSocketFactory;
+import org.apache.commons.httpclient.protocol.DefaultProtocolSocketFactory;
+import org.apache.commons.httpclient.protocol.Protocol;
+import org.apache.commons.httpclient.protocol.ProtocolSocketFactory;
+import org.apache.commons.ssl.KeyMaterial;
+import org.apache.commons.ssl.SSLClient;
+import org.apache.log4j.Logger;
+import org.jboss.soa.esb.ConfigurationException;
+import org.jboss.soa.esb.http.Configurator;
+import org.jboss.soa.esb.http.protocol.ProtocolSocketFactoryBuilder;
+import org.jboss.soa.esb.util.ClassUtil;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.security.GeneralSecurityException;
+import java.security.KeyManagementException;
+import java.security.KeyStoreException;
+import java.security.NoSuchAlgorithmException;
+import java.security.cert.CertificateException;
+import java.util.Properties;
+
+/**
+ * HTTP Connection configurator.
+ * <p/>
+ * Properties:
+ * <ul>
+ * <li><b>max-total-connections</b>: Maximum total number of connection for the HttpClient.</li>
+ * </ul>
+ * <p/>
+ *
+ * @author <a href="mailto:tom.fennelly at jboss.com">tom.fennelly at jboss.com</a>
+ */
+public class Connection extends Configurator {
+
+ private Logger logger = Logger.getLogger(Connection.class);
+ /**
+ * Max total connections.
+ */
+ public static final String MAX_TOTAL_CONNECTIONS = "max-total-connections";
+
+ public void configure(HttpClient httpClient, Properties properties) throws ConfigurationException {
+ final HttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager() ;
+ final String maxTotalConnections = properties.getProperty(MAX_TOTAL_CONNECTIONS) ;
+
+ if (maxTotalConnections != null) {
+ final HttpConnectionManagerParams params = new HttpConnectionManagerParams() ;
+ try {
+ params.setMaxTotalConnections(Integer.parseInt(maxTotalConnections)) ;
+ } catch (final NumberFormatException nfe) {
+ throw new ConfigurationException("Invalid " + MAX_TOTAL_CONNECTIONS + " property: " + maxTotalConnections) ;
+ }
+ connectionManager.setParams(params) ;
+ }
+
+ httpClient.setHttpConnectionManager(connectionManager);
+ }
+}
\ No newline at end of file
Property changes on: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/http/configurators/Connection.java
___________________________________________________________________
Name: svn:mergeinfo
+
Name: svn:eol-style
+ native
More information about the jboss-svn-commits
mailing list