Java Code Example org.apache.http.impl.conn.PoolingClientConnectionManager
Java Code Examples for org.apache.http.impl.conn.PoolingClientConnectionManager
The following are top voted examples for showing how to use
org.apache.http.impl.conn.PoolingClientConnectionManager. These examples are extracted from open source projects.
You can vote up the examples you like and your votes will be used in our system to product
more good examples.
+ Save this class to your library
private Client getJerseyClient() {
if ( jerseyClient == null ) {
synchronized ( this ) {
// create HTTPClient and with configured connection pool
int poolSize = 100; // connections
final String poolSizeStr = properties.getProperty( CENTRAL_CONNECTION_POOL_SIZE );
if ( poolSizeStr != null ) {
poolSize = Integer.parseInt( poolSizeStr );
PoolingClientConnectionManager connectionManager = new PoolingClientConnectionManager();
connectionManager.setMaxTotal(poolSize);
int timeout = 20000; // ms
final String timeoutStr = properties.getProperty( CENTRAL_CONNECTION_TIMEOUT );
if ( timeoutStr != null ) {
timeout = Integer.parseInt( timeoutStr );
int readTimeout = 20000; // ms
final String readTimeoutStr = properties.getProperty( CENTRAL_READ_TIMEOUT );
if ( readTimeoutStr != null ) {
readTimeout = Integer.parseInt( readTimeoutStr );
ClientConfig clientConfig = new ClientConfig();
clientConfig.register( new JacksonFeature() );
clientConfig.property( ApacheClientProperties.CONNECTION_MANAGER, connectionManager );
clientConfig.connectorProvider( new ApacheConnectorProvider() );
jerseyClient = ClientBuilder.newClient( clientConfig );
jerseyClient.property( ClientProperties.CONNECT_TIMEOUT, timeout );
jerseyClient.property( ClientProperties.READ_TIMEOUT, readTimeout );
return jerseyC
HttpClientPoolFactory(String host, int port, boolean useHttps, int timeout,
boolean clientAuth, String keyStore, String keyPass,
String trustStore, String trustPass, String adminToken,
int maxActive, long timeBetweenEvictionRunsMillis,
long minEvictableIdleTimeMillis) {
// Setup auth URL
String protocol = useHttps ? &https://& : &http://&;
String urlStr = protocol + host + &:& +
uri = URI.create(urlStr);
// Setup connection pool
SchemeRegistry schemeRegistry = new SchemeRegistry();
if (protocol.startsWith(&https&)) {
SSLSocketFactory sslf = sslFactory(keyStore, keyPass, trustStore,
trustPass, clientAuth);
schemeRegistry.register(new Scheme(&https&, port, sslf));
schemeRegistry.register(new Scheme(&http&, port, PlainSocketFactory
.getSocketFactory()));
connMgr = new PoolingClientConnectionManager(schemeRegistry,
minEvictableIdleTimeMillis, TimeUnit.MILLISECONDS);
connMgr.setMaxTotal(maxActive);
connMgr.setDefaultMaxPerRoute(maxActive);
// Http connection timeout
HttpParams params = new BasicHttpParams();
params.setParameter(CoreConnectionPNames.SO_TIMEOUT, timeout);
params.setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, timeout);
// Create a single client
client = new DefaultHttpClient(connMgr, params);
// Create and start the connection pool cleaner
cleaner = new HttpPoolCleaner(connMgr, timeBetweenEvictionRunsMillis,
minEvictableIdleTimeMillis);
new Thread(cleaner).start();
* Create an HttpClient that performs connection pooling. This can be used
#setDefaultHttpClient} or provided in the HttpOp calls.
public static HttpClient createCachingHttpClient() {
return new SystemDefaultHttpClient() {
* See SystemDefaultHttpClient (4.2). This version always sets the
* connection cache
protected ClientConnectionManager createClientConnectionManager() {
PoolingClientConnectionManager connmgr = new PoolingClientConnectionManager(
SchemeRegistryFactory.createSystemDefault());
String s = System.getProperty(&http.maxConnections&, &5&);
int max = Integer.parseInt(s);
connmgr.setDefaultMaxPerRoute(max);
connmgr.setMaxTotal(2 * max);
public DefaultHttpTransportService(ThreadPoolService threadPoolService, Settings settings) {
this.threadPoolService = threadPoolS
this.settings =
PoolingClientConnectionManager poolingClientConnectionManager = new PoolingClientConnectionManager();
poolingClientConnectionManager.setMaxTotal(settings.getAsInt(&http.client.max_total&, 100));
poolingClientConnectionManager.setDefaultMaxPerRoute(settings.getAsInt(&http.client.default_max_per_route&, 50));
final HttpParams httpParams = new BasicHttpParams();
HttpConnectionParams.setConnectionTimeout(httpParams, settings.getAsInt(&http.client.connect.timeout&, 5000));
HttpConnectionParams.setSoTimeout(httpParams, settings.getAsInt(&http.client.accept.timeout&, 5000));
httpClient = new DefaultHttpClient(poolingClientConnectionManager, httpParams);
* Connection manager to allow concurrent connections.
ClientConnectionManager} instance
public static ClientConnectionManager getConnectionManager() {
PoolingClientConnectionManager connManager = new PoolingClientConnectionManager(
SchemeRegistryFactory.createDefault());
connManager.setMaxTotal(100);
connManager.setDefaultMaxPerRoute(30);
return connM
protected HttpClient createHttpClient() {
SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(new Scheme(&http&, 80, PlainSocketFactory
.getSocketFactory()));
schemeRegistry.register(new Scheme(&https&, 443, SSLSocketFactory
.getSocketFactory()));
PoolingClientConnectionManager cm = new PoolingClientConnectionManager(schemeRegistry);
cm.setMaxTotal(maxTotalConnections);
cm.setDefaultMaxPerRoute(defaultMaxConnectionsPerHost);
HttpClient httpClient = new DefaultHttpClient(cm);
return httpC
public static void main(String[] args) throws Exception {
// Create an HttpClient with the ThreadSafeClientConnManager.
// This connection manager must be used if more than one thread will
// be using the HttpClient.
PoolingClientConnectionManager cm = new PoolingClientConnectionManager();
cm.setMaxTotal(100);
HttpClient httpclient = new DefaultHttpClient(cm);
// create an array of URIs to perform GETs on
String[] urisToGet = {
&http://hc.apache.org/&,
&http://hc.apache.org/httpcomponents-core-ga/&,
&http://hc.apache.org/httpcomponents-client-ga/&,
&http://svn.apache.org/viewvc/httpcomponents/&
// create a thread for each URI
GetThread[] threads = new GetThread[urisToGet.length];
for (int i = 0; i & threads. i++) {
HttpGet httpget = new HttpGet(urisToGet[i]);
threads[i] = new GetThread(httpclient, httpget, i + 1);
// start the threads
for (int j = 0; j & threads. j++) {
threads[j].start();
// join the threads
for (int j = 0; j & threads. j++) {
threads[j].join();
} finally {
// When HttpClient instance is no longer needed,
// shut down the connection manager to ensure
// immediate deallocation of all system resources
httpclient.getConnectionManager().shutdown();
public static void main(String[] args) throws Exception {
// Create an HttpClient with the ThreadSafeClientConnManager.
// This connection manager must be used if more than one thread will
// be using the HttpClient.
PoolingClientConnectionManager cm = new PoolingClientConnectionManager();
cm.setMaxTotal(100);
HttpClient httpclient = new DefaultHttpClient(cm);
// create an array of URIs to perform GETs on
String[] urisToGet = {
&http://hc.apache.org/&,
&http://hc.apache.org/httpcomponents-core-ga/&,
&http://hc.apache.org/httpcomponents-client-ga/&,
&http://svn.apache.org/viewvc/httpcomponents/&
// create a thread for each URI
GetThread[] threads = new GetThread[urisToGet.length];
for (int i = 0; i & threads. i++) {
HttpGet httpget = new HttpGet(urisToGet[i]);
threads[i] = new GetThread(httpclient, httpget, i + 1);
// start the threads
for (int j = 0; j & threads. j++) {
threads[j].start();
// join the threads
for (int j = 0; j & threads. j++) {
threads[j].join();
} finally {
// When HttpClient instance is no longer needed,
// shut down the connection manager to ensure
// immediate deallocation of all system resources
httpclient.getConnectionManager().shutdown();
private static HttpClient createHttpClient(SOSMetadata metadata) {
PoolingClientConnectionManager cm = new PoolingClientConnectionManager();
cm.setMaxTotal(metadata.getHttpConnectionPoolSize());
int timeout = metadata.getTimeout();
SimpleHttpClient simpleClient = new SimpleHttpClient(timeout, timeout, cm);
return new GzipEnabledHttpClient(new ProxyAwareHttpClient(simpleClient));
Example 10
public DefaultWmsHttpClientFactory() {
final PoolingClientConnectionManager cm = new PoolingClientConnectionManager();
cm.setMaxTotal(100);
cm.setDefaultMaxPerRoute(100);
client = new SystemDefaultHttpClient() {
protected ClientConnectionManager createClientConnectionManager() {
client.getParams().setIntParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 30000);
client.getParams().setParameter(CoreConnectionPNames.TCP_NODELAY, true);
client.getParams().setParameter(CoreConnectionPNames.SO_TIMEOUT, 30000);
Example 11
public static ClientConnectionManager newConnectionManager( SslConfig sslConfig )
SchemeRegistry schemeReg = new SchemeRegistry();
schemeReg.register( new Scheme( &http&, 80, new PlainSocketFactory() ) );
schemeReg.register( new Scheme( &https&, 443, new SslSocketFactory( sslConfig ) ) );
PoolingClientConnectionManager connMgr = new PoolingClientConnectionManager( schemeReg );
connMgr.setMaxTotal( 100 );
connMgr.setDefaultMaxPerRoute( 50 );
return connM
Example 12
private static HttpClient createDefaultHttpClient()
HttpClient httpC
if (Registry.isRegitered(HttpClient.class)) {
httpClient = Registry.lookup(HttpClient.class);
SchemeRegistry schreg = SchemeRegistryFactory.createSystemDefault();
PoolingClientConnectionManager pool = new PoolingClientConnectionManager(schreg);
pool.setDefaultMaxPerRoute(100);
pool.setMaxTotal(200);
DefaultHttpClient hc = new DefaultHttpClient(pool);
HttpParams params = hc.getParams();
HttpConnectionParamBean connBean = new HttpConnectionParamBean(params);
connBean.setConnectionTimeout(300000);
HttpProtocolParamBean protocolBean = new HttpProtocolParamBean(params);
VersionInfo versionInfo = VersionInfo.loadVersionInfo(&glaze&, DefaultSyncClient.class.getClassLoader());
protocolBean.setUserAgent(String.format(&Glaze-HttpClient/%s&, versionInfo));
httpClient =
return httpC
Example 13
static PoolingClientConnectionManager createConnectionManager(
int maxConnections) throws KeyStoreException,
NoSuchAlgorithmException, CertificateException, IOException,
KeyManagementException, UnrecoverableKeyException {
SSLSocketFactory factory = NaiveSSLFactory.createNaiveSSLSocketFactory();
SchemeRegistry registry = new SchemeRegistry();
registry.register(new Scheme(&http&, 80, PlainSocketFactory.getSocketFactory()));
registry.register(new Scheme(&https&, 443, factory));
PoolingClientConnectionManager manager = new PoolingClientConnectionManager(registry);
manager.setMaxTotal(maxConnections);
manager.setDefaultMaxPerRoute(maxConnections);
Example 14
public void shouldReduceConnectionPool() throws Exception {
ExecutorService executorService = Executors.newFixedThreadPool(10);
PoolingClientConnectionManager conman = new PoolingClientConnectionManager();
conman.setDefaultMaxPerRoute(20);
final TestHttpClient client = new TestHttpClient(conman);
int requests = 1000;
final CountDownLatch latch = new CountDownLatch(requests);
for (int i = 0; i & ++i) {
executorService.submit(new Runnable() {
public void run() {
HttpGet get = new HttpGet(&http://& + host + &:& + (port + 1));
client.execute(get, new ResponseHandler&HttpResponse&() {
public HttpResponse handleResponse(HttpResponse response) throws IOException {
latch.countDown();
Assert.assertEquals(StatusCodes.OK, response.getStatusLine().getStatusCode());
} catch (IOException e) {
throw new RuntimeException(e);
latch.await(2000, TimeUnit.MILLISECONDS);
} finally {
executorService.shutdownNow();
client.getConnectionManager().shutdown();
Assert.assertEquals(2, activeConnections.size());
Thread.sleep(4000);
Assert.assertEquals(0, activeConnections.size());
Example 15
public ClientConnectionManager getConnectionManager() {
PoolingClientConnectionManager cm = new PoolingClientConnectionManager(schemeRegistry);
// Increase max total connection to 200
cm.setMaxTotal(200);
// Increase default max connection per route to 20
cm.setDefaultMaxPerRoute(20);
// Increase max connections for localhost:80 to 50
HttpHost localhost8080 = new HttpHost(&localhost&, 8080);
cm.setMaxPerRoute(new HttpRoute(localhost8080), 50);
HttpHost localhost = new HttpHost(&localhost&, 80);
cm.setMaxPerRoute(new HttpRoute(localhost), 50);
Example 16
protected static ClientConfig createHttpBasicClientConfig(final String userName, final String password) {
final HttpParams params = new BasicHttpParams();
DefaultHttpClient.setDefaultHttpParams(params);
params.setBooleanParameter(CoreConnectionPNames.SO_REUSEADDR, true);
params.setBooleanParameter(CoreProtocolPNames.USE_EXPECT_CONTINUE, true);
params.setBooleanParameter(CoreConnectionPNames.STALE_CONNECTION_CHECK, true);
final SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(new Scheme(&http&, 80, PlainSocketFactory.getSocketFactory()));
final PoolingClientConnectionManager mgr = new PoolingClientConnectionManager(schemeRegistry);
mgr.setMaxTotal(200);
mgr.setDefaultMaxPerRoute(20);
final DefaultHttpClient httpClient = new DefaultHttpClient(mgr, params);
final Credentials credentials = new UsernamePasswordCredentials(userName, password);
httpClient.getCredentialsProvider().setCredentials(AuthScope.ANY, credentials);
httpClient.addRequestInterceptor(new PreemptiveAuthInterceptor(), 0);
ClientConfig clientConfig = new ApacheHttpClientConfig(httpClient);
clientConfig.setBypassHostnameVerification(true);
return clientC
Example 17
public ClientConnectionManager configureConnectionManager(
HttpParams params) throws ArangoDb4JException {
if (conman == null) {
SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(configureScheme());
PoolingClientConnectionManager cm = new PoolingClientConnectionManager(schemeRegistry);
cm.setMaxTotal(maxConnections);
cm.setDefaultMaxPerRoute(maxConnections);
if (cleanupIdleConnections) {
IdleConnectionMonitor.monitor(conman);
Example 18
* (non-Javadoc)
* @see com.sematext.ag.sink.Sink#init(com.sematext.ag.PlayerConfig)
public void init(PlayerConfig config) throws InitializationFailedException {
super.init(config);
PoolingClientConnectionManager connectionManager = (PoolingClientConnectionManager) HTTP_CLIENT_INSTANCE
.getConnectionManager();
if (config.get(MAXIMUM_CONNECTIONS_PER_ROUTE_KEY) != null
&& !config.get(MAXIMUM_CONNECTIONS_PER_ROUTE_KEY).isEmpty()) {
connectionManager.setDefaultMaxPerRoute(Integer.parseInt(config.get(MAXIMUM_CONNECTIONS_PER_ROUTE_KEY)));
if (config.get(MAXIMUM_CONNECTIONS_TOTAL_KEY) != null && !config.get(MAXIMUM_CONNECTIONS_TOTAL_KEY).isEmpty()) {
connectionManager.setMaxTotal(Integer.parseInt(config.get(MAXIMUM_CONNECTIONS_TOTAL_KEY)));
Example 19
private void initHttpClient() {
SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(
new Scheme(&http&, 80, PlainSocketFactory.getSocketFactory()));
schemeRegistry.register(
new Scheme(&https&, 443, SSLSocketFactory.getSocketFactory()));
PoolingClientConnectionManager cm = new PoolingClientConnectionManager(schemeRegistry);
cm.setDefaultMaxPerRoute(16);
cm.setMaxTotal(64);
this.httpClient = new DefaultHttpClient(cm);
Example 20
public PageFetcher(CrawlConfig config) {
super(config);
HttpParams params = new BasicHttpParams();
HttpProtocolParamBean paramsBean = new HttpProtocolParamBean(params);
paramsBean.setVersion(HttpVersion.HTTP_1_1);
paramsBean.setContentCharset(&UTF-8&);
paramsBean.setUseExpectContinue(false);
params.setParameter(ClientPNames.COOKIE_POLICY, CookiePolicy.BROWSER_COMPATIBILITY);
params.setParameter(CoreProtocolPNames.USER_AGENT, config.getUserAgentString());
params.setIntParameter(CoreConnectionPNames.SO_TIMEOUT, config.getSocketTimeout());
params.setIntParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, config.getConnectionTimeout());
params.setBooleanParameter(&http.protocol.handle-redirects&, false);
SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(new Scheme(&http&, 80, PlainSocketFactory.getSocketFactory()));
if (config.isIncludeHttpsPages()) {
//schemeRegistry.register(new Scheme(&https&, 443, SSLSocketFactory.getSocketFactory()));
schemeRegistry.register(new Scheme(&https&, 443, config.getHttpsSocketFactory()));
connectionManager = new PoolingClientConnectionManager(schemeRegistry);
connectionManager.setMaxTotal(config.getMaxTotalConnections());
connectionManager.setDefaultMaxPerRoute(config.getMaxConnectionsPerHost());
httpClient = new DefaultHttpClient(connectionManager, params);
if (config.getProxyHost() != null) {
if (config.getProxyUsername() != null) {
httpClient.getCredentialsProvider().setCredentials(
new AuthScope(config.getProxyHost(), config.getProxyPort()),
new UsernamePasswordCredentials(config.getProxyUsername(), config.getProxyPassword()));
HttpHost proxy = new HttpHost(config.getProxyHost(), config.getProxyPort());
httpClient.getParams().setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy);
httpClient.addResponseInterceptor(new HttpResponseInterceptor() {
public void process(final HttpResponse response, final HttpContext context) throws HttpException,
IOException {
HttpEntity entity = response.getEntity();
Header contentEncoding = entity.getContentEncoding();
if (contentEncoding != null) {
HeaderElement[] codecs = contentEncoding.getElements();
for (HeaderElement codec : codecs) {
if (codec.getName().equalsIgnoreCase(&gzip&)) {
response.setEntity(new GzipDecompressingEntity(response.getEntity()));
if (connectionMonitorThread == null) {
connectionMonitorThread = new IdleConnectionMonitorThread(connectionManager);
connectionMonitorThread.start();Right click on identifier in code to find usages!
Hot Sneaks
Pepper Grinder
Smoothness
Swanky Purse
1&&&&*&====================================================================3&&&&*&Licensed&to&the&Apache&Software&Foundation&(ASF)&under&one4&&&&*&or&more&contributor&license&agreements.&&See&the&NOTICE&file5&&&&*&distributed&with&this&work&for&additional&information6&&&&*&regarding&copyright&ownership.&&The&ASF&licenses&this&file7&&&&*&to&you&under&the&Apache&License,&Version&2.0&(the8&&&&*&"License");&you&may&not&use&this&file&except&in&compliance9&&&&*&with&the&License.&&You&may&obtain&a&copy&of&the&License&at10&&&*11&&&*&&&http://www.apache.org/licenses/LICENSE-2.012&&&*13&&&*&Unless&required&by&applicable&law&or&agreed&to&in&writing,14&&&*&software&distributed&under&the&License&is&distributed&on&an15&&&*&"AS&IS"&BASIS,&WITHOUT&WARRANTIES&OR&CONDITIONS&OF&ANY16&&&*&KIND,&either&express&or&implied.&&See&the&License&for&the17&&&*&specific&language&governing&permissions&and&limitations18&&&*&under&the&License.19&&&*&====================================================================20&&&*21&&&*&This&software&consists&of&voluntary&contributions&made&by&many22&&&*&individuals&on&behalf&of&the&Apache&Software&Foundation.&&For&more23&&&*&information&on&the&Apache&Software&Foundation,&please&see24&&&*&&http://www.apache.org/&.25&&&*26&&&*/27&&package&org.apache.http.impl.nio.conn;28&&29&&import&java.io.;30&&import&java..;31&&import&java..;32&&import&java..;33&&import&java.util.;34&&import&java.util..;35&&import&java.util..;36&&import&java.util..;37&&38&&import&org.apache.commons.logging.;39&&import&org.apache.commons.logging.;40&&import&org.apache.http.;41&&import&org.apache.http.concurrent.;42&&import&org.apache.http.concurrent.;43&&import&org.apache.http.config.;44&&import&org.apache.http.config.;45&&import&org.apache.http.config.;46&&import&org.apache.http.config.;47&&import&org.apache.http.conn.;48&&import&org.apache.http.conn.;49&&import&org.apache.http.conn.routing.;50&&import&org.apache.http.impl.conn.;51&&import&org.apache.http.impl.conn.;52&&import&org.apache.http.nio.;53&&import&org.apache.http.nio.conn.;54&&import&org.apache.http.nio.conn.;55&&import&org.apache.http.nio.conn.;56&&import&org.apache.http.nio.conn.;57&&import&org.apache.http.nio.conn.;58&&import&org.apache.http.nio.conn.ssl.;59&&import&org.apache.http.nio.pool.;60&&import&org.apache.http.nio.pool.;61&&import&org.apache.http.nio.reactor.;62&&import&org.apache.http.nio.reactor.;63&&import&org.apache.http.nio.reactor.;64&&import&org.apache.http.pool.;65&&import&org.apache.http.pool.;66&&import&org.apache.http.protocol.;67&&import&org.apache.http.util.;68&&import&org.apache.http.util.;69&&70&&public&class&71&&&&&&&&&implements&,&&&&{72&&73&&&&&&private&final&&&=&.(());74&&75&&&&&&private&final&&;76&&&&&&private&final&&;77&&&&&&private&final&&;78&&&&&&private&final&&&&;79&&80&&&&&&private&static&&&&()&{81&&&&&&&&&&return&.&&()82&&&&&&&&&&&&&&&&&&.("http",&.)83&&&&&&&&&&&&&&&&&&.("https",&.())84&&&&&&&&&&&&&&&&&&.();85&&&&&&}86&&87&&&&&&public&(final&&)&{88&&&&&&&&&&(,&());89&&&&&&}90&&91&&&&&&public&(92&&&&&&&&&&&&&&final&&,93&&&&&&&&&&&&&&final&&&&)&{94&&&&&&&&&&(,&null,&,&null);95&&&&&&}96&&97&&&&&&public&(98&&&&&&&&&&&&&&final&&,99&&&&&&&&&&&&&&final&&&&,100&&&&&&&&&&&&&final&&)&{101&&&&&&&&&(,&,&(),&);102&&&&&}103&104&&&&&public&(105&&&&&&&&&&&&&final&&,106&&&&&&&&&&&&&final&&&&)&{107&&&&&&&&&(,&,&(),&null);108&&&&&}109&110&&&&&public&(111&&&&&&&&&&&&&final&&,112&&&&&&&&&&&&&final&&&&,113&&&&&&&&&&&&&final&&&&)&{114&&&&&&&&&(,&,&,&null);115&&&&&}116&117&&&&&public&(118&&&&&&&&&&&&&final&&,119&&&&&&&&&&&&&final&&&&,120&&&&&&&&&&&&&final&&&&,121&&&&&&&&&&&&&final&&)&{122&&&&&&&&&(,&,&,&null,&,123&&&&&&&&&&&&&-1,&.);124&&&&&}125&126&&&&&public&(127&&&&&&&&&&&&&final&&,128&&&&&&&&&&&&&final&&&&,129&&&&&&&&&&&&&final&&&&,130&&&&&&&&&&&&&final&&,131&&&&&&&&&&&&&final&&,132&&&&&&&&&&&&&final&long&,&final&&)&{133&&&&&&&&&super();134&&&&&&&&&.(,&"I/O&reactor");135&&&&&&&&&.(,&"I/O&session&factory&registry");136&&&&&&&&&this.&=&;137&&&&&&&&&this.&=&new&();138&&&&&&&&&this.&=&new&(,139&&&&&&&&&&&&&new&(this.,&),140&&&&&&&&&&&&&new&(,&),141&&&&&&&&&&&&&2,&20,&,&&!=&null&?&&:&.);142&&&&&&&&&this.&=&;143&&&&&}144&145&&&&&(146&&&&&&&&&&&&&final&&,147&&&&&&&&&&&&&final&&,148&&&&&&&&&&&&&final&&&&,149&&&&&&&&&&&&&final&&,150&&&&&&&&&&&&&final&&,151&&&&&&&&&&&&&final&long&,&final&&)&{152&&&&&&&&&super();153&&&&&&&&&this.&=&;154&&&&&&&&&this.&=&new&();155&&&&&&&&&this.&=&;156&&&&&&&&&this.&=&;157&&&&&}158&159&&&&&@160&&&&&protected&void&()&throws&&{161&&&&&&&&&try&{162&&&&&&&&&&&&&();163&&&&&&&&&}&finally&{164&&&&&&&&&&&&&super.();165&&&&&&&&&}166&&&&&}167&168&&&&&public&void&(final&&)&throws&&{169&&&&&&&&&this..();170&&&&&}171&172&&&&&public&void&(final&long&)&throws&&{173&&&&&&&&&this..("Connection&manager&is&shutting&down");174&&&&&&&&&this..();175&&&&&&&&&this..("Connection&manager&shut&down");176&&&&&}177&178&&&&&public&void&()&throws&&{179&&&&&&&&&this..("Connection&manager&is&shutting&down");180&&&&&&&&&this..(2000);181&&&&&&&&&this..("Connection&manager&shut&down");182&&&&&}183&184&&&&&private&&(final&&,&final&&)&{185&&&&&&&&&final&&&=&new&();186&&&&&&&&&.("[route:&").().("]");187&&&&&&&&&if&(&!=&null)&{188&&&&&&&&&&&&&.("[state:&").().("]");189&&&&&&&&&}190&&&&&&&&&return&.();191&&&&&}192&193&&&&&private&&(final&&)&{194&&&&&&&&&final&&&=&new&();195&&&&&&&&&final&&&=&this..();196&&&&&&&&&final&&&=&this..();197&&&&&&&&&.("[total&kept&alive:&").(.()).(";&");198&&&&&&&&&.("route&allocated:&").(.()&+&.());199&&&&&&&&&.("&of&").(.()).(";&");200&&&&&&&&&.("total&allocated:&").(.()&+&.());201&&&&&&&&&.("&of&").(.()).("]");202&&&&&&&&&return&.();203&&&&&}204&205&&&&&private&&(final&&)&{206&&&&&&&&&final&&&=&new&();207&&&&&&&&&.("[id:&").(.()).("]");208&&&&&&&&&.("[route:&").(.()).("]");209&&&&&&&&&final&&&=&.();210&&&&&&&&&if&(&!=&null)&{211&&&&&&&&&&&&&.("[state:&").().("]");212&&&&&&&&&}213&&&&&&&&&return&.();214&&&&&}215&216&&&&&public&&&&(217&&&&&&&&&&&&&final&&,218&&&&&&&&&&&&&final&&,219&&&&&&&&&&&&&final&long&,220&&&&&&&&&&&&&final&&,221&&&&&&&&&&&&&final&&&&)&{222&&&&&&&&&.(,&"HTTP&route");223&&&&&&&&&if&(this..())&{224&&&&&&&&&&&&&this..("Connection&request:&"&+&(,&)&+&());225&&&&&&&&&}226&&&&&&&&&final&&&&&=&new&&&();227&&&&&&&&&final&&;228&&&&&&&&&if&(.()&!=&null)&{229&&&&&&&&&&&&&&=&.();230&&&&&&&&&}&else&{231&&&&&&&&&&&&&&=&.();232&&&&&&&&&}233&&&&&&&&&final&&&=&this..(234&&&&&&&&&&&&&&&&&.());235&&&&&&&&&if&(&==&null)&{236&&&&&&&&&&&&&.(new&("Unsupported&scheme:&"&+&.()));237&&&&&&&&&&&&&return&;238&&&&&&&&&}239&&&&&&&&&this..(,&,&,240&&&&&&&&&&&&&&&&&&!=&null&?&&:&.,241&&&&&&&&&&&&&&&&&new&());242&&&&&&&&&return&;243&&&&&}244&245&&&&&public&void&(246&&&&&&&&&&&&&final&&,247&&&&&&&&&&&&&final&&,248&&&&&&&&&&&&&final&long&,249&&&&&&&&&&&&&final&&)&{250&&&&&&&&&.(,&"Managed&connection");251&&&&&&&&&synchronized&()&{252&&&&&&&&&&&&&final&&&=&.();253&&&&&&&&&&&&&if&(&==&null)&{254&&&&&&&&&&&&&&&&&return;255&&&&&&&&&&&&&}256&&&&&&&&&&&&&final&&&=&.();257&&&&&&&&&&&&&try&{258&&&&&&&&&&&&&&&&&if&(.())&{259&&&&&&&&&&&&&&&&&&&&&.();260&&&&&&&&&&&&&&&&&&&&&.(,&&!=&null&?&&:&.);261&&&&&&&&&&&&&&&&&&&&&if&(this..())&{262&&&&&&&&&&&&&&&&&&&&&&&&&&;263&&&&&&&&&&&&&&&&&&&&&&&&&if&(&&&0)&{264&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&=&"for&"&+&(double)&&/&1000&+&"&seconds";265&&&&&&&&&&&&&&&&&&&&&&&&&}&else&{266&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&=&"indefinitely";267&&&&&&&&&&&&&&&&&&&&&&&&&}268&&&&&&&&&&&&&&&&&&&&&&&&&this..("Connection&"&+&()&+&"&can&be&kept&alive&"&+&);269&&&&&&&&&&&&&&&&&&&&&}270&&&&&&&&&&&&&&&&&}271&&&&&&&&&&&&&}&finally&{272&&&&&&&&&&&&&&&&&this..(,&.()&&&&.());273&&&&&&&&&&&&&&&&&if&(this..())&{274&&&&&&&&&&&&&&&&&&&&&this..("Connection&released:&"&+&()&+&(.()));275&&&&&&&&&&&&&&&&&}276&&&&&&&&&&&&&}277&&&&&&&&&}278&&&&&}279&280&&&&&public&void&(281&&&&&&&&&&&&&final&&,282&&&&&&&&&&&&&final&&,283&&&&&&&&&&&&&final&&)&throws&&{284&&&&&&&&&.(,&"Managed&connection");285&&&&&&&&&.(,&"HTTP&route");286&&&&&&&&&final&&;287&&&&&&&&&if&(.()&!=&null)&{288&&&&&&&&&&&&&&=&.();289&&&&&&&&&}&else&{290&&&&&&&&&&&&&&=&.();291&&&&&&&&&}292&&&&&&&&&final&&&=&this..(293&&&&&&&&&&&&&&&&&.());294&&&&&&&&&if&(&==&null)&{295&&&&&&&&&&&&&throw&new&("Unsupported&scheme:&"&+&.());296&&&&&&&&&}297&&&&&&&&&synchronized&()&{298&&&&&&&&&&&&&final&&&=&.();299&&&&&&&&&&&&&final&&&=&.();300&&&&&&&&&&&&&final&&&=&.(,&.());301&&&&&&&&&&&&&.();302&&&&&&&&&}303&&&&&}304&305&&&&&public&void&(306&&&&&&&&&&&&&final&&,307&&&&&&&&&&&&&final&&,308&&&&&&&&&&&&&final&&)&throws&&{309&&&&&&&&&.(,&"Managed&connection");310&&&&&&&&&.(,&"HTTP&route");311&&&&&&&&&final&&&&=&.();312&&&&&&&&&final&&&=&this..(313&&&&&&&&&&&&&.());314&&&&&&&&&if&(&==&null)&{315&&&&&&&&&&&&&throw&new&("Unsupported&scheme:&"&+&.());316&&&&&&&&&}317&&&&&&&&&synchronized&()&{318&&&&&&&&&&&&&final&&&=&.();319&&&&&&&&&&&&&final&&&=&.();320&&&&&&&&&&&&&.(.(),&"Layering&is&not&supported&for&this&scheme");321&&&&&&&&&&&&&final&&&=&.(,&.());322&&&&&&&&&&&&&.();323&&&&&&&&&}324&&&&&}325&326&&&&&public&void&(327&&&&&&&&&&&&&final&&,328&&&&&&&&&&&&&final&&,329&&&&&&&&&&&&&final&&)&{330&&&&&&&&&.(,&"Managed&connection");331&&&&&&&&&.(,&"HTTP&route");332&&&&&&&&&synchronized&()&{333&&&&&&&&&&&&&final&&&=&.();334&&&&&&&&&&&&&.();335&&&&&&&&&}336&&&&&}337&338&&&&&public&boolean&(339&&&&&&&&&&&&&final&&)&{340&&&&&&&&&.(,&"Managed&connection");341&&&&&&&&&synchronized&()&{342&&&&&&&&&&&&&final&&&=&.();343&&&&&&&&&&&&&return&.();344&&&&&&&&&}345&&&&&}346&347&&&&&public&void&(final&long&,&final&&)&{348&&&&&&&&&if&(this..())&{349&&&&&&&&&&&&&this..("Closing&connections&idle&longer&than&"&+&&+&"&"&+&);350&&&&&&&&&}351&&&&&&&&&this..(,&);352&&&&&}353&354&&&&&public&void&()&{355&&&&&&&&&.("Closing&expired&connections");356&&&&&&&&&this..();357&&&&&}358&359&&&&&public&int&()&{360&&&&&&&&&return&this..();361&&&&&}362&363&&&&&public&void&(final&int&)&{364&&&&&&&&&this..();365&&&&&}366&367&&&&&public&int&()&{368&&&&&&&&&return&this..();369&&&&&}370&371&&&&&public&void&(final&int&)&{372&&&&&&&&&this..();373&&&&&}374&375&&&&&public&int&(final&&)&{376&&&&&&&&&return&this..();377&&&&&}378&379&&&&&public&void&(final&&,&final&int&)&{380&&&&&&&&&this..(,&);381&&&&&}382&383&&&&&public&&()&{384&&&&&&&&&return&this..();385&&&&&}386&387&&&&&public&&(final&&)&{388&&&&&&&&&return&this..();389&&&&&}390&391&&&&&public&&()&{392&&&&&&&&&return&this..();393&&&&&}394&395&&&&&public&void&(final&&)&{396&&&&&&&&&this..();397&&&&&}398&399&&&&&public&&()&{400&&&&&&&&&return&this..();401&&&&&}402&403&&&&&public&void&(final&&)&{404&&&&&&&&&this..();405&&&&&}406&407&&&&&public&&(final&&)&{408&&&&&&&&&return&this..();409&&&&&}410&411&&&&&public&void&(final&&,&final&&)&{412&&&&&&&&&this..(,&);413&&&&&}414&415&&&&&public&&(final&&)&{416&&&&&&&&&return&this..();417&&&&&}418&419&&&&&public&void&(final&&,&final&&)&{420&&&&&&&&&this..(,&);421&&&&&}422&423&&&&&class&&implements&&&&{424&425&&&&&&&&&private&final&&&&;426&427&&&&&&&&&public&(428&&&&&&&&&&&&&&&&&final&&&&)&{429&&&&&&&&&&&&&super();430&&&&&&&&&&&&&this.&=&;431&&&&&&&&&}432&433&&&&&&&&&public&void&(final&&)&{434&&&&&&&&&&&&&.(.()&!=&null,&"Pool&entry&with&no&connection");435&&&&&&&&&&&&&if&(.())&{436&&&&&&&&&&&&&&&&&.("Connection&leased:&"&+&()&+&(.()));437&&&&&&&&&&&&&}438&&&&&&&&&&&&&final&&&=&.();439&&&&&&&&&&&&&if&(!this..())&{440&&&&&&&&&&&&&&&&&.(,&true);441&&&&&&&&&&&&&}442&&&&&&&&&}443&444&&&&&&&&&public&void&(final&&)&{445&&&&&&&&&&&&&if&(.())&{446&&&&&&&&&&&&&&&&&.("Connection&request&failed",&);447&&&&&&&&&&&&&}448&&&&&&&&&&&&&this..();449&&&&&&&&&}450&451&&&&&&&&&public&void&()&{452&&&&&&&&&&&&&.("Connection&request&cancelled");453&&&&&&&&&&&&&this..(true);454&&&&&&&&&}455&456&&&&&}457&458&&&&&static&class&&{459&460&&&&&&&&&private&final&&,&&&;461&&&&&&&&&private&final&&,&&&;462&&&&&&&&&private&volatile&&;463&&&&&&&&&private&volatile&&;464&465&&&&&&&&&()&{466&&&&&&&&&&&&&super();467&&&&&&&&&&&&&this.&=&new&&,&&();468&&&&&&&&&&&&&this.&=&new&&,&&();469&&&&&&&&&}470&471&&&&&&&&&public&&()&{472&&&&&&&&&&&&&return&this.;473&&&&&&&&&}474&475&&&&&&&&&public&void&(final&&)&{476&&&&&&&&&&&&&this.&=&;477&&&&&&&&&}478&479&&&&&&&&&public&&()&{480&&&&&&&&&&&&&return&this.;481&&&&&&&&&}482&483&&&&&&&&&public&void&(final&&)&{484&&&&&&&&&&&&&this.&=&;485&&&&&&&&&}486&487&&&&&&&&&public&&(final&&)&{488&&&&&&&&&&&&&return&this..();489&&&&&&&&&}490&491&&&&&&&&&public&void&(final&&,&final&&)&{492&&&&&&&&&&&&&this..(,&);493&&&&&&&&&}494&495&&&&&&&&&public&&(final&&)&{496&&&&&&&&&&&&&return&this..();497&&&&&&&&&}498&499&&&&&&&&&public&void&(final&&,&final&&)&{500&&&&&&&&&&&&&this..(,&);501&&&&&&&&&}502&503&&&&&}504&505&&&&&static&class&&implements&&,&&&{506&507&&&&&&&&&private&final&&;508&&&&&&&&&private&final&&&&;509&510&&&&&&&&&(511&&&&&&&&&&&&&&&&&final&&,512&&&&&&&&&&&&&&&&&final&&&&)&{513&&&&&&&&&&&&&super();514&&&&&&&&&&&&&this.&=&&!=&null&?&&:&new&();515&&&&&&&&&&&&&this.&=&&!=&null&?&&:516&&&&&&&&&&&&&&&&&.;517&&&&&&&&&}518&519&&&&&&&&&public&&(520&&&&&&&&&&&&&&&&&final&&,&final&&)&throws&&{521&&&&&&&&&&&&&&&=&null;522&&&&&&&&&&&&&if&(.()&!=&null)&{523&&&&&&&&&&&&&&&&&&=&this..(.());524&&&&&&&&&&&&&}525&&&&&&&&&&&&&if&(&==&null)&{526&&&&&&&&&&&&&&&&&&=&this..(.());527&&&&&&&&&&&&&}528&&&&&&&&&&&&&if&(&==&null)&{529&&&&&&&&&&&&&&&&&&=&this..();530&&&&&&&&&&&&&}531&&&&&&&&&&&&&if&(&==&null)&{532&&&&&&&&&&&&&&&&&&=&.;533&&&&&&&&&&&&&}534&&&&&&&&&&&&&final&&&=&this..(,&);535&&&&&&&&&&&&&.(.,&);536&&&&&&&&&&&&&return&;537&&&&&&&&&}538&539&&&&&}540&541&&&&&static&class&&implements&&&&{542&543&&&&&&&&&private&final&&;544&&&&&&&&&private&final&&;545&546&&&&&&&&&public&(547&&&&&&&&&&&&&&&&&final&&,548&&&&&&&&&&&&&&&&&final&&)&{549&&&&&&&&&&&&&super();550&&&&&&&&&&&&&this.&=&&!=&null&?&&:551&&&&&&&&&&&&&&&&&.;552&&&&&&&&&&&&&this.&=&&!=&null&?&&:553&&&&&&&&&&&&&&&&&&&&&.;554&&&&&&&&&}555&556&&&&&&&&&public&&(final&&)&throws&&{557&&&&&&&&&&&&&return&.()&!=&null&?&new&(.(),&0)&:&null;558&&&&&&&&&}559&560&&&&&&&&&public&&(final&&)&throws&&{561&&&&&&&&&&&&&final&&;562&&&&&&&&&&&&&if&(.()&!=&null)&{563&&&&&&&&&&&&&&&&&&=&.();564&&&&&&&&&&&&&}&else&{565&&&&&&&&&&&&&&&&&&=&.();566&&&&&&&&&&&&&}567&&&&&&&&&&&&&final&int&&=&this..();568&&&&&&&&&&&&&final&[]&&=&this..(.());569&&&&&&&&&&&&&return&new&([0],&);570&&&&&&&&&}571&572&&&&&}573&}574&575&}