Skip to content

Commit c44eba8

Browse files
committed
allow user to call connectionManager's closeIdleConnections
1 parent a14ace4 commit c44eba8

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

src/main/java/com/github/dockerjava/jaxrs/JerseyDockerCmdExecFactory.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
import java.net.URI;
1010
import java.net.URISyntaxException;
1111
import java.util.List;
12+
import java.util.concurrent.TimeUnit;
1213

1314
import javax.net.ssl.SSLContext;
1415
import javax.ws.rs.client.Client;
@@ -266,7 +267,7 @@ private void configureProxy(ClientConfig clientConfig, URI originalUri, String p
266267
}
267268

268269
private org.apache.http.config.Registry<ConnectionSocketFactory> getSchemeRegistry(final URI originalUri,
269-
SSLContext sslContext) {
270+
SSLContext sslContext) {
270271
RegistryBuilder<ConnectionSocketFactory> registryBuilder = RegistryBuilder.create();
271272
registryBuilder.register("http", PlainConnectionSocketFactory.getSocketFactory());
272273
if (sslContext != null) {
@@ -589,4 +590,14 @@ public JerseyDockerCmdExecFactory withClientRequestFilters(ClientRequestFilter..
589590
return this;
590591
}
591592

593+
594+
/**
595+
* release connections from the pool
596+
*
597+
* @param idleSeconds idle seconds, longer than the configured value will be evicted
598+
*/
599+
public void releaseConnection(long idleSeconds) {
600+
this.connManager.closeExpiredConnections();
601+
this.connManager.closeIdleConnections(idleSeconds, TimeUnit.SECONDS);
602+
}
592603
}

0 commit comments

Comments
 (0)