| 1 | |
|
| 2 | |
|
| 3 | |
|
| 4 | |
|
| 5 | |
|
| 6 | |
|
| 7 | |
|
| 8 | |
|
| 9 | |
|
| 10 | |
|
| 11 | |
|
| 12 | |
|
| 13 | |
|
| 14 | |
|
| 15 | |
|
| 16 | |
package org.kuali.rice.ksb.messaging; |
| 17 | |
|
| 18 | |
import org.apache.commons.httpclient.HttpMethodRetryHandler; |
| 19 | |
import org.apache.commons.httpclient.HttpVersion; |
| 20 | |
import org.apache.commons.httpclient.params.HostParams; |
| 21 | |
import org.apache.commons.httpclient.params.HttpClientParams; |
| 22 | |
import org.apache.commons.httpclient.params.HttpConnectionManagerParams; |
| 23 | |
import org.apache.commons.httpclient.params.HttpConnectionParams; |
| 24 | |
import org.apache.commons.httpclient.params.HttpMethodParams; |
| 25 | |
import org.apache.commons.httpclient.params.HttpParams; |
| 26 | |
import org.kuali.rice.core.api.util.ClassLoaderUtils; |
| 27 | |
|
| 28 | |
import java.util.Collection; |
| 29 | |
import java.util.HashMap; |
| 30 | |
import java.util.Map; |
| 31 | |
|
| 32 | |
|
| 33 | |
|
| 34 | |
|
| 35 | |
|
| 36 | |
|
| 37 | |
|
| 38 | |
|
| 39 | |
|
| 40 | |
|
| 41 | |
|
| 42 | 0 | public class HttpClientHelper { |
| 43 | |
|
| 44 | |
|
| 45 | |
|
| 46 | |
|
| 47 | 0 | private static final Map<String, Class<?>> PARAM_TYPE_MAP = new HashMap<String, Class<?>>(); |
| 48 | |
static { |
| 49 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.PROTOCOL_VERSION, HttpVersion.class); |
| 50 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.UNAMBIGUOUS_STATUS_LINE, Boolean.class); |
| 51 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.SINGLE_COOKIE_HEADER, Boolean.class); |
| 52 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.STRICT_TRANSFER_ENCODING, Boolean.class); |
| 53 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.REJECT_HEAD_BODY, Boolean.class); |
| 54 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.HEAD_BODY_CHECK_TIMEOUT, Integer.class); |
| 55 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.USE_EXPECT_CONTINUE, Boolean.class); |
| 56 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.WARN_EXTRA_INPUT, Boolean.class); |
| 57 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.STATUS_LINE_GARBAGE_LIMIT, Integer.class); |
| 58 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.SO_TIMEOUT, Integer.class); |
| 59 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.RETRY_HANDLER, HttpMethodRetryHandler.class); |
| 60 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.DATE_PATTERNS, Collection.class); |
| 61 | 0 | PARAM_TYPE_MAP.put(HttpMethodParams.BUFFER_WARN_TRIGGER_LIMIT, Integer.class); |
| 62 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.SO_TIMEOUT, Integer.class); |
| 63 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.TCP_NODELAY, Boolean.class); |
| 64 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.SO_SNDBUF, Integer.class); |
| 65 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.SO_RCVBUF, Integer.class); |
| 66 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.SO_LINGER, Integer.class); |
| 67 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.CONNECTION_TIMEOUT, Integer.class); |
| 68 | 0 | PARAM_TYPE_MAP.put(HttpConnectionParams.STALE_CONNECTION_CHECK, Boolean.class); |
| 69 | 0 | PARAM_TYPE_MAP.put(HttpConnectionManagerParams.MAX_HOST_CONNECTIONS, Map.class); |
| 70 | 0 | PARAM_TYPE_MAP.put(HttpConnectionManagerParams.MAX_TOTAL_CONNECTIONS, Integer.class); |
| 71 | 0 | PARAM_TYPE_MAP.put(HostParams.DEFAULT_HEADERS, Collection.class); |
| 72 | 0 | PARAM_TYPE_MAP.put(HttpClientParams.CONNECTION_MANAGER_TIMEOUT, Long.class); |
| 73 | 0 | PARAM_TYPE_MAP.put(HttpClientParams.CONNECTION_MANAGER_CLASS, Class.class); |
| 74 | 0 | PARAM_TYPE_MAP.put(HttpClientParams.PREEMPTIVE_AUTHENTICATION, Boolean.class); |
| 75 | 0 | PARAM_TYPE_MAP.put(HttpClientParams.REJECT_RELATIVE_REDIRECT, Boolean.class); |
| 76 | 0 | PARAM_TYPE_MAP.put(HttpClientParams.MAX_REDIRECTS, Integer.class); |
| 77 | 0 | PARAM_TYPE_MAP.put(HttpClientParams.ALLOW_CIRCULAR_REDIRECTS, Boolean.class); |
| 78 | 0 | } |
| 79 | |
|
| 80 | |
public static void setParameter(HttpParams params, String paramName, String paramValue) { |
| 81 | 0 | Class<?> paramType = getParameterType(paramName); |
| 82 | 0 | if (paramType.equals(Boolean.class)) { |
| 83 | 0 | params.setBooleanParameter(paramName, Boolean.parseBoolean(paramValue)); |
| 84 | 0 | } else if (paramType.equals(Integer.class)) { |
| 85 | 0 | params.setIntParameter(paramName, Integer.parseInt(paramValue)); |
| 86 | 0 | } else if (paramType.equals(Long.class)) { |
| 87 | 0 | params.setLongParameter(paramName, Long.parseLong(paramValue)); |
| 88 | 0 | } else if (paramType.equals(Double.class)) { |
| 89 | 0 | params.setDoubleParameter(paramName, Double.parseDouble(paramValue)); |
| 90 | 0 | } else if (paramType.equals(String.class)) { |
| 91 | 0 | params.setParameter(paramName, paramValue); |
| 92 | 0 | } else if (paramType.equals(Class.class)) { |
| 93 | |
try { |
| 94 | 0 | Class<?> configuredClass = Class.forName(paramValue, true, ClassLoaderUtils.getDefaultClassLoader()); |
| 95 | 0 | params.setParameter(paramName, configuredClass); |
| 96 | 0 | } catch (ClassNotFoundException e) { |
| 97 | 0 | throw new RuntimeException("Could not locate the class needed to configure the HttpClient.", e); |
| 98 | 0 | } |
| 99 | |
} else { |
| 100 | 0 | throw new RuntimeException("Attempted to configure an HttpClient parameter '" + paramName + "' " + |
| 101 | |
"of a type not supported through Workflow configuration: " + paramType.getName()); |
| 102 | |
} |
| 103 | 0 | } |
| 104 | |
|
| 105 | |
|
| 106 | |
|
| 107 | |
|
| 108 | |
public static Class getParameterType(String parameterName) { |
| 109 | 0 | Class<?> parameterType = PARAM_TYPE_MAP.get(parameterName); |
| 110 | 0 | if (parameterType == null) { |
| 111 | 0 | parameterType = String.class; |
| 112 | |
} |
| 113 | 0 | return parameterType; |
| 114 | |
} |
| 115 | |
|
| 116 | |
} |