@@ -145,13 +145,13 @@ private HttpClientConnectionManager createConnectionPool(URI uri) {
145
145
Validate .notNull (uri , "URI must not be null" );
146
146
log .debug (() -> "Creating ConnectionPool for: URI:" + uri + ", MaxConns: " + maxConnectionsPerEndpoint );
147
147
148
- HttpClientConnectionManagerOptions options = new HttpClientConnectionManagerOptions ();
149
- options .withClientBootstrap (bootstrap )
150
- .withSocketOptions (socketOptions )
151
- .withTlsContext (tlsContext )
152
- .withUri (uri )
153
- .withWindowSize (windowSize )
154
- .withMaxConnections (maxConnectionsPerEndpoint );
148
+ HttpClientConnectionManagerOptions options = new HttpClientConnectionManagerOptions ()
149
+ .withClientBootstrap (bootstrap )
150
+ .withSocketOptions (socketOptions )
151
+ .withTlsContext (tlsContext )
152
+ .withUri (uri )
153
+ .withWindowSize (windowSize )
154
+ .withMaxConnections (maxConnectionsPerEndpoint );
155
155
156
156
return HttpClientConnectionManager .create (options );
157
157
}
@@ -244,7 +244,6 @@ public CompletableFuture<Void> execute(AsyncExecuteRequest asyncRequest) {
244
244
// When a Connection is ready from the Connection Pool, schedule the Request on the connection
245
245
crtConnPool .acquireConnection ()
246
246
.whenComplete ((crtConn , throwable ) -> {
247
-
248
247
// If we didn't get a connection for some reason, fail the request
249
248
if (throwable != null ) {
250
249
requestFuture .completeExceptionally (throwable );
0 commit comments