Fix default proxy resolver

reactor · Feb 27, 2017 · bd7bcf8 · bd7bcf8
1 parent 3f7e9ff
commit bd7bcf8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/reactor/ipc/netty/options/ClientOptions.java b/src/main/java/reactor/ipc/netty/options/ClientOptions.java
@@ -39,6 +39,7 @@
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.resolver.AddressResolverGroup;
+import io.netty.resolver.DefaultAddressResolverGroup;
 import io.netty.resolver.NoopAddressResolverGroup;
 import io.netty.util.NetUtil;
 import reactor.core.Exceptions;
@@ -361,7 +362,7 @@ public ClientOptions proxy(@Nonnull Proxy type,
 		this.proxyPassword = password;
 		this.proxyAddress = Objects.requireNonNull(connectAddress, "addressSupplier");
 		this.proxyType = Objects.requireNonNull(type, "proxyType");
-		if(bootstrapTemplate.config().resolver() == null){
+		if(bootstrapTemplate.config().resolver() == DefaultAddressResolverGroup.INSTANCE){
 			resolver(NoopAddressResolverGroup.INSTANCE);
 		}
 		return this;