org.kuali.rice.ksb.messaging.serviceconnectors
Class HttpInvokerConnector

java.lang.Object
  org.kuali.rice.ksb.messaging.serviceconnectors.AbstractServiceConnector
      org.kuali.rice.ksb.messaging.serviceconnectors.HttpInvokerConnector

All Implemented Interfaces:

ServiceConnector

public class HttpInvokerConnector
extends AbstractServiceConnector

Since:

0.9

Author:

Kuali Rice Team (rice.collab@kuali.org)

Nested Class Summary

private static class

HttpInvokerConnector.CustomHttpMethodRetryHandler

Field Summary

private static String	DEFAULT_IDLE_CONNECTION_THREAD_INTERVAL
private static String	DEFAULT_IDLE_CONNECTION_TIMEOUT
private boolean	httpClientInitialized
private org.apache.commons.httpclient.params.HttpClientParams	httpClientParams
private static org.apache.commons.httpclient.util.IdleConnectionTimeoutThread	ictt
private static String	IDLE_CONNECTION_THREAD_INTERVAL_PROPERTY
private static String	IDLE_CONNECTION_TIMEOUT_PROPERTY
private static org.apache.log4j.Logger	LOG
private static String	RETRY_SOCKET_EXCEPTION_PROPERTY

Constructor Summary

HttpInvokerConnector(ServiceInfo serviceInfo)

Method Summary

protected void	configureDefaultHttpClientParams(org.apache.commons.httpclient.params.HttpParams params)
org.apache.commons.httpclient.HttpClient	getHttpClient() Creates a commons HttpClient for service invocation.
Object	getService()
protected void	initializeHttpClientParams()
private void	runIdleConnectionTimeout() Idle connection timeout thread added as a part of the fix for ensuring that threads that timed out need to be cleaned or and send back to the pool so that other clients can use it.
static void	shutdownIdleConnectionTimeout()

Methods inherited from class org.kuali.rice.ksb.messaging.serviceconnectors.AbstractServiceConnector

getCredentialsSource, getServiceInfo, getServiceProxyWithFailureMode, setCredentialsSource, setServiceInfo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.apache.log4j.Logger LOG

httpClientParams

private org.apache.commons.httpclient.params.HttpClientParams httpClientParams

httpClientInitialized

private boolean httpClientInitialized

IDLE_CONNECTION_THREAD_INTERVAL_PROPERTY

private static final String IDLE_CONNECTION_THREAD_INTERVAL_PROPERTY

See Also:

Constant Field Values

IDLE_CONNECTION_TIMEOUT_PROPERTY

private static final String IDLE_CONNECTION_TIMEOUT_PROPERTY

See Also:

Constant Field Values

DEFAULT_IDLE_CONNECTION_THREAD_INTERVAL

private static final String DEFAULT_IDLE_CONNECTION_THREAD_INTERVAL

See Also:

Constant Field Values

DEFAULT_IDLE_CONNECTION_TIMEOUT

private static final String DEFAULT_IDLE_CONNECTION_TIMEOUT

See Also:

Constant Field Values

RETRY_SOCKET_EXCEPTION_PROPERTY

private static final String RETRY_SOCKET_EXCEPTION_PROPERTY

See Also:

Constant Field Values

ictt

private static org.apache.commons.httpclient.util.IdleConnectionTimeoutThread ictt

Constructor Detail

HttpInvokerConnector

public HttpInvokerConnector(ServiceInfo serviceInfo)

Method Detail

getService

public Object getService()
                  throws Exception

Throws:

Exception

getHttpClient

public org.apache.commons.httpclient.HttpClient getHttpClient()

Creates a commons HttpClient for service invocation. Config parameters that start with http.* are used to configure the client. TODO we need to add support for other invocation protocols and implementations, but for now...

initializeHttpClientParams

protected void initializeHttpClientParams()

configureDefaultHttpClientParams

protected void configureDefaultHttpClientParams(org.apache.commons.httpclient.params.HttpParams params)

runIdleConnectionTimeout

private void runIdleConnectionTimeout()

Idle connection timeout thread added as a part of the fix for ensuring that threads that timed out need to be cleaned or and send back to the pool so that other clients can use it.

shutdownIdleConnectionTimeout

public static void shutdownIdleConnectionTimeout()