in src/main/java/org/apache/solr/mcf/ManifoldCFSearchComponent.java [96:135]
public void init(NamedList args)
{
super.init(args);
authorityBaseURL = (String)args.get("AuthorityServiceBaseURL");
if (authorityBaseURL == null)
{
LOG.info("USING DEFAULT BASE URL!!");
authorityBaseURL = "http://localhost:8345/mcf-authority-service";
}
Integer cTimeOut = (Integer)args.get("ConnectionTimeOut");
connectionTimeOut = cTimeOut == null ? 60000 : cTimeOut;
Integer timeOut = (Integer)args.get("SocketTimeOut");
socketTimeOut = timeOut == null ? 300000 : timeOut;
String allowAttributePrefix = (String)args.get("AllowAttributePrefix");
String denyAttributePrefix = (String)args.get("DenyAttributePrefix");
if (allowAttributePrefix == null)
allowAttributePrefix = "allow_token_";
if (denyAttributePrefix == null)
denyAttributePrefix = "deny_token_";
fieldAllowDocument = allowAttributePrefix+"document";
fieldDenyDocument = denyAttributePrefix+"document";
fieldAllowShare = allowAttributePrefix+"share";
fieldDenyShare = denyAttributePrefix+"share";
fieldAllowParent = allowAttributePrefix+"parent";
fieldDenyParent = denyAttributePrefix+"parent";
Integer connectionPoolSize = (Integer)args.get("ConnectionPoolSize");
poolSize = (connectionPoolSize==null)?50:connectionPoolSize.intValue();
// 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());
}