(camel-quarkus) 02/02: [NettyHttp] Increase proxy connection timeout and make it configurable

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch 3.8.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit d58c1c602c98e73c8c9176ceb6d4e1157b32102d
Author: Andrej Vano <av...@redhat.com>
AuthorDate: Thu Apr 4 14:19:19 2024 +0200

    [NettyHttp] Increase proxy connection timeout and make it configurable
---
 .../apache/camel/quarkus/component/http/common/HttpTestResource.java    | 1 +
 .../component/http/netty/ProxyCapableClientInitializerFactory.java      | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/integration-test-groups/http/common/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
 
b/integration-test-groups/http/common/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
index 72ddc21652..270e4dfdff 100644
--- 
a/integration-test-groups/http/common/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
+++ 
b/integration-test-groups/http/common/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
@@ -52,6 +52,7 @@ public class HttpTestResource implements 
QuarkusTestResourceLifecycleManager {
                 "camel.netty-http.https-test-port",
                 "camel.netty-http.compression-test-port");
         options.put("proxy.host", "localhost");
+        options.put("proxy.connection.timeout", "10000");
 
         server = new ProxyServer(Integer.parseInt(options.get("proxy.port")), 
USER_ADMIN, USER_ADMIN_PASSWORD);
         server.start();
diff --git 
a/integration-test-groups/http/netty-http/src/main/java/org/apache/camel/quarkus/component/http/netty/ProxyCapableClientInitializerFactory.java
 
b/integration-test-groups/http/netty-http/src/main/java/org/apache/camel/quarkus/component/http/netty/ProxyCapableClientInitializerFactory.java
index 9f3e544684..f1a8b36471 100644
--- 
a/integration-test-groups/http/netty-http/src/main/java/org/apache/camel/quarkus/component/http/netty/ProxyCapableClientInitializerFactory.java
+++ 
b/integration-test-groups/http/netty-http/src/main/java/org/apache/camel/quarkus/component/http/netty/ProxyCapableClientInitializerFactory.java
@@ -46,7 +46,7 @@ public class ProxyCapableClientInitializerFactory extends 
HttpClientInitializerF
         Integer proxyPort = config.getValue("proxy.port", Integer.class);
         InetSocketAddress proxyServerAddress = new 
InetSocketAddress(proxyHost, proxyPort);
         HttpProxyHandler httpProxyHandler = new 
HttpProxyHandler(proxyServerAddress, USER_ADMIN, USER_ADMIN_PASSWORD);
-        httpProxyHandler.setConnectTimeoutMillis(5000);
+        
httpProxyHandler.setConnectTimeoutMillis(config.getValue("proxy.connection.timeout",
 Long.class));
         super.initChannel(channel);
         channel.pipeline().addFirst(httpProxyHandler);
     }