diff --git a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/io/HttpRequestExecutor.java b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/io/HttpRequestExecutor.java index 5208c0fc9f..84400643ae 100644 --- a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/io/HttpRequestExecutor.java +++ b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/io/HttpRequestExecutor.java @@ -183,7 +183,7 @@ public ClassicHttpResponse execute( } response = null; continue; - } else if (status >= HttpStatus.SC_CLIENT_ERROR) { + } else if (status >= HttpStatus.SC_REDIRECTION) { conn.terminateRequest(request); } else { conn.sendRequestEntity(request); diff --git a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java index b54c603dbf..8206fd3f7e 100644 --- a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java +++ b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java @@ -234,7 +234,7 @@ void consumeHeader(final HttpResponse response, final EntityDetails entityDetail if (status == HttpStatus.SC_CONTINUE || status >= HttpStatus.SC_SUCCESS) { outputChannel.setSocketTimeout(timeout); requestState.set(MessageState.BODY); - if (status < HttpStatus.SC_CLIENT_ERROR) { + if (status < HttpStatus.SC_REDIRECTION) { exchangeHandler.produce(internalDataChannel); } } @@ -243,7 +243,7 @@ void consumeHeader(final HttpResponse response, final EntityDetails entityDetail return; } if (requestState.get() == MessageState.BODY) { - if (status >= HttpStatus.SC_CLIENT_ERROR) { + if (status >= HttpStatus.SC_REDIRECTION) { requestState.set(MessageState.COMPLETE); if (!outputChannel.abortGracefully()) { keepAlive = false;