|
33 | 33 | import org.apache.hc.client5.http.io.DetachedSocketFactory;
|
34 | 34 | import org.apache.hc.client5.http.io.HttpClientConnectionManager;
|
35 | 35 | import org.apache.hc.client5.http.routing.HttpRoutePlanner;
|
| 36 | +import org.apache.hc.client5.http.ssl.TlsSocketStrategy; |
36 | 37 | import org.apache.hc.core5.http.HttpHost;
|
| 38 | +import org.apache.hc.core5.http.config.Lookup; |
37 | 39 | import org.apache.hc.core5.http.protocol.HttpContext;
|
38 | 40 | import org.apache.hc.core5.util.TimeValue;
|
39 | 41 |
|
@@ -77,12 +79,20 @@ private static class LocalConnectionManager extends BasicHttpClientConnectionMan
|
77 | 79 | .setValidateAfterInactivity(TimeValue.NEG_ONE_MILLISECOND)
|
78 | 80 | .build();
|
79 | 81 |
|
| 82 | + private static final Lookup<TlsSocketStrategy> NO_TLS_SOCKET = (name) -> null; |
| 83 | + |
80 | 84 | LocalConnectionManager(ResolvedDockerHost dockerHost) {
|
81 |
| - super(new DefaultHttpClientConnectionOperator(new LocalDetachedSocketFactory(dockerHost), null, |
82 |
| - new LocalDnsResolver(), (name) -> null), null); |
| 85 | + super(createhttpClientConnectionOperator(dockerHost), null); |
83 | 86 | setConnectionConfig(CONNECTION_CONFIG);
|
84 | 87 | }
|
85 | 88 |
|
| 89 | + private static DefaultHttpClientConnectionOperator createhttpClientConnectionOperator( |
| 90 | + ResolvedDockerHost dockerHost) { |
| 91 | + LocalDetachedSocketFactory detachedSocketFactory = new LocalDetachedSocketFactory(dockerHost); |
| 92 | + LocalDnsResolver dnsResolver = new LocalDnsResolver(); |
| 93 | + return new DefaultHttpClientConnectionOperator(detachedSocketFactory, null, dnsResolver, NO_TLS_SOCKET); |
| 94 | + } |
| 95 | + |
86 | 96 | }
|
87 | 97 |
|
88 | 98 | /**
|
|
0 commit comments