diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java index 1886aa080e9b..abd045e552b2 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java @@ -327,7 +327,7 @@ protected boolean onExpired(HttpChannel channel) if (exchange != null) { HttpRequest request = exchange.getRequest(); - request.abort(new TimeoutException("Total timeout " + request.getTimeout() + " ms elapsed")); + request.abort(new TimeoutException("Total timeout " + request.getConversation().getTimeout() + " ms elapsed")); } return false; } diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java index 571dea7aa97d..903a959323dc 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java @@ -544,7 +544,7 @@ protected Iterator iterator() protected boolean onExpired(HttpExchange exchange) { HttpRequest request = exchange.getRequest(); - request.abort(new TimeoutException("Total timeout " + request.getTimeout() + " ms elapsed")); + request.abort(new TimeoutException("Total timeout " + request.getConversation().getTimeout() + " ms elapsed")); return false; } } diff --git a/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientRedirectTest.java b/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientRedirectTest.java index 9a7a4065b854..1dd89a95d3a6 100644 --- a/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientRedirectTest.java +++ b/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientRedirectTest.java @@ -506,14 +506,16 @@ protected void service(String target, Request jettyRequest, HttpServletRequest r } }); - assertThrows(TimeoutException.class, () -> + long timeout = 1000; + TimeoutException timeoutException = assertThrows(TimeoutException.class, () -> { client.setMaxRedirects(-1); client.newRequest("localhost", connector.getLocalPort()) .scheme(scenario.getScheme()) - .timeout(1, TimeUnit.SECONDS) + .timeout(timeout, TimeUnit.MILLISECONDS) .send(); }); + assertThat(timeoutException.getMessage(), Matchers.containsString(String.valueOf(timeout))); } @ParameterizedTest