in src/main/java/org/apache/solr/mcf/ManifoldCFQParserPlugin.java [114:134]
protected void initializeClient(SolrCore core)
{
synchronized (connectionManagerSynchronizer)
{
if (client == null)
{
// Initialize the connection pool
httpConnectionManager = new ThreadSafeClientConnManager();
httpConnectionManager.setMaxTotal(poolSize);
httpConnectionManager.setDefaultMaxPerRoute(poolSize);
BasicHttpParams params = new BasicHttpParams();
params.setBooleanParameter(CoreConnectionPNames.TCP_NODELAY,true);
params.setBooleanParameter(CoreConnectionPNames.STALE_CONNECTION_CHECK,true);
params.setIntParameter(CoreConnectionPNames.SO_TIMEOUT,socketTimeOut);
params.setIntParameter(CoreConnectionPNames.CONNECTION_TIMEOUT,connectionTimeOut);
client = new DefaultHttpClient(httpConnectionManager,params);
client.setRedirectStrategy(new DefaultRedirectStrategy());
core.addCloseHook(new CloseHandler());
}
}
}