Add a private method to refresh proxy DNS.

line · Nov 17, 2024 · 979e6fd · 979e6fd
1 parent 18b24ea
commit 979e6fd
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/src/main/java/com/linecorp/armeria/client/HttpClientDelegate.java b/core/src/main/java/com/linecorp/armeria/client/HttpClientDelegate.java
@@ -237,7 +237,7 @@ private void resolveProxyConfig(SessionProtocol protocol, Endpoint endpoint, Cli
         if (proxyConfig.proxyAddress() != null) {
             final Future<InetSocketAddress> resolveFuture = addressResolverGroup
                     .getResolver(ctx.eventLoop().withoutContext())
-                    .resolve(proxyConfig.proxyAddress());
+                    .resolve(createUnresolvedAddressForRefreshing(proxyConfig.proxyAddress()));
 
             resolveFuture.addListener(future -> {
                 if (future.isSuccess()) {
@@ -302,4 +302,8 @@ private static void doExecute(PooledChannel pooledChannel, ClientRequestContext
         res.init(session.inboundTrafficController());
         session.invoke(pooledChannel, ctx, req, res);
     }
+
+    private static InetSocketAddress createUnresolvedAddressForRefreshing(InetSocketAddress previousAddress) {
+        return new InetSocketAddress(previousAddress.getHostName(), previousAddress.getPort());
+    }
 }