| @@ -116,11 +116,14 @@ public void acquireEndpoint( |
|
|
| 116 |
116 |
log.debug("{} acquired endpoint {}", id, ConnPoolSupport.getId(connectionEndpoint)); |
| 117 |
117 |
} |
| 118 |
118 |
} catch(final TimeoutException ex) { |
|
119 |
+connRequest.cancel(); |
| 119 |
120 |
throw new ConnectionRequestTimeoutException(ex.getMessage()); |
| 120 |
121 |
} catch(final InterruptedException interrupted) { |
|
122 |
+connRequest.cancel(); |
| 121 |
123 |
Thread.currentThread().interrupt(); |
| 122 |
124 |
throw new RequestFailedException("Request aborted", interrupted); |
| 123 |
125 |
} catch(final ExecutionException ex) { |
|
126 |
+connRequest.cancel(); |
| 124 |
127 |
Throwable cause = ex.getCause(); |
| 125 |
128 |
if (cause == null) { |
| 126 |
129 |
cause = ex; |