001 /*
002 * Copyright 2005-2007 The Kuali Foundation
003 *
004 *
005 * Licensed under the Educational Community License, Version 2.0 (the "License");
006 * you may not use this file except in compliance with the License.
007 * You may obtain a copy of the License at
008 *
009 * http://www.opensource.org/licenses/ecl2.php
010 *
011 * Unless required by applicable law or agreed to in writing, software
012 * distributed under the License is distributed on an "AS IS" BASIS,
013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
014 * See the License for the specific language governing permissions and
015 * limitations under the License.
016 */
017 package org.kuali.rice.ksb.messaging;
018
019 import java.util.Collection;
020 import java.util.HashMap;
021 import java.util.Map;
022
023 import org.apache.commons.httpclient.HttpMethodRetryHandler;
024 import org.apache.commons.httpclient.HttpVersion;
025 import org.apache.commons.httpclient.params.HostParams;
026 import org.apache.commons.httpclient.params.HttpClientParams;
027 import org.apache.commons.httpclient.params.HttpConnectionManagerParams;
028 import org.apache.commons.httpclient.params.HttpConnectionParams;
029 import org.apache.commons.httpclient.params.HttpMethodParams;
030 import org.apache.commons.httpclient.params.HttpParams;
031 import org.kuali.rice.core.util.ClassLoaderUtils;
032
033
034 /**
035 * Contains some utility methods for dealing with configuration of the
036 * Commons HttpClient library. Specifically, HttpClient parameters are
037 * typed, so we can't just pipe the String values from or configuration
038 * through. Instead we need to know the type of all the different
039 * HttpClient parameters and set the parameter accordingly.
040 *
041 * @author Kuali Rice Team (rice.collab@kuali.org)
042 */
043 public class HttpClientHelper {
044
045 /**
046 * A Map which defines the type for all non-String parameters for HttpClient.
047 */
048 private static final Map<String, Class<?>> PARAM_TYPE_MAP = new HashMap<String, Class<?>>();
049 static {
050 PARAM_TYPE_MAP.put(HttpMethodParams.PROTOCOL_VERSION, HttpVersion.class);
051 PARAM_TYPE_MAP.put(HttpMethodParams.UNAMBIGUOUS_STATUS_LINE, Boolean.class);
052 PARAM_TYPE_MAP.put(HttpMethodParams.SINGLE_COOKIE_HEADER, Boolean.class);
053 PARAM_TYPE_MAP.put(HttpMethodParams.STRICT_TRANSFER_ENCODING, Boolean.class);
054 PARAM_TYPE_MAP.put(HttpMethodParams.REJECT_HEAD_BODY, Boolean.class);
055 PARAM_TYPE_MAP.put(HttpMethodParams.HEAD_BODY_CHECK_TIMEOUT, Integer.class);
056 PARAM_TYPE_MAP.put(HttpMethodParams.USE_EXPECT_CONTINUE, Boolean.class);
057 PARAM_TYPE_MAP.put(HttpMethodParams.WARN_EXTRA_INPUT, Boolean.class);
058 PARAM_TYPE_MAP.put(HttpMethodParams.STATUS_LINE_GARBAGE_LIMIT, Integer.class);
059 PARAM_TYPE_MAP.put(HttpMethodParams.SO_TIMEOUT, Integer.class);
060 PARAM_TYPE_MAP.put(HttpMethodParams.RETRY_HANDLER, HttpMethodRetryHandler.class);
061 PARAM_TYPE_MAP.put(HttpMethodParams.DATE_PATTERNS, Collection.class);
062 PARAM_TYPE_MAP.put(HttpMethodParams.BUFFER_WARN_TRIGGER_LIMIT, Integer.class);
063 PARAM_TYPE_MAP.put(HttpConnectionParams.SO_TIMEOUT, Integer.class);
064 PARAM_TYPE_MAP.put(HttpConnectionParams.TCP_NODELAY, Boolean.class);
065 PARAM_TYPE_MAP.put(HttpConnectionParams.SO_SNDBUF, Integer.class);
066 PARAM_TYPE_MAP.put(HttpConnectionParams.SO_RCVBUF, Integer.class);
067 PARAM_TYPE_MAP.put(HttpConnectionParams.SO_LINGER, Integer.class);
068 PARAM_TYPE_MAP.put(HttpConnectionParams.CONNECTION_TIMEOUT, Integer.class);
069 PARAM_TYPE_MAP.put(HttpConnectionParams.STALE_CONNECTION_CHECK, Boolean.class);
070 PARAM_TYPE_MAP.put(HttpConnectionManagerParams.MAX_HOST_CONNECTIONS, Map.class);
071 PARAM_TYPE_MAP.put(HttpConnectionManagerParams.MAX_TOTAL_CONNECTIONS, Integer.class);
072 PARAM_TYPE_MAP.put(HostParams.DEFAULT_HEADERS, Collection.class);
073 PARAM_TYPE_MAP.put(HttpClientParams.CONNECTION_MANAGER_TIMEOUT, Long.class);
074 PARAM_TYPE_MAP.put(HttpClientParams.CONNECTION_MANAGER_CLASS, Class.class);
075 PARAM_TYPE_MAP.put(HttpClientParams.PREEMPTIVE_AUTHENTICATION, Boolean.class);
076 PARAM_TYPE_MAP.put(HttpClientParams.REJECT_RELATIVE_REDIRECT, Boolean.class);
077 PARAM_TYPE_MAP.put(HttpClientParams.MAX_REDIRECTS, Integer.class);
078 PARAM_TYPE_MAP.put(HttpClientParams.ALLOW_CIRCULAR_REDIRECTS, Boolean.class);
079 }
080
081 public static void setParameter(HttpParams params, String paramName, String paramValue) {
082 Class<?> paramType = getParameterType(paramName);
083 if (paramType.equals(Boolean.class)) {
084 params.setBooleanParameter(paramName, Boolean.parseBoolean(paramValue));
085 } else if (paramType.equals(Integer.class)) {
086 params.setIntParameter(paramName, Integer.parseInt(paramValue));
087 } else if (paramType.equals(Long.class)) {
088 params.setLongParameter(paramName, Long.parseLong(paramValue));
089 } else if (paramType.equals(Double.class)) {
090 params.setDoubleParameter(paramName, Double.parseDouble(paramValue));
091 } else if (paramType.equals(String.class)) {
092 params.setParameter(paramName, paramValue);
093 } else if (paramType.equals(Class.class)) {
094 try {
095 Class<?> configuredClass = Class.forName(paramValue, true, ClassLoaderUtils.getDefaultClassLoader());
096 params.setParameter(paramName, configuredClass);
097 } catch (ClassNotFoundException e) {
098 throw new RuntimeException("Could not locate the class needed to configure the HttpClient.", e);
099 }
100 } else {
101 throw new RuntimeException("Attempted to configure an HttpClient parameter '" + paramName + "' " +
102 "of a type not supported through Workflow configuration: " + paramType.getName());
103 }
104 }
105
106 /**
107 * Returns the expected type of the given HttpClient parameter. String is the default.
108 */
109 public static Class getParameterType(String parameterName) {
110 Class<?> parameterType = PARAM_TYPE_MAP.get(parameterName);
111 if (parameterType == null) {
112 parameterType = String.class;
113 }
114 return parameterType;
115 }
116
117 }