diff --git a/resolver-dns/src/test/java/io/netty/resolver/dns/DnsAddressResolverGroupTest.java b/resolver-dns/src/test/java/io/netty/resolver/dns/DnsAddressResolverGroupTest.java index 4caaa55fdca..ce6d6b612b8 100644 --- a/resolver-dns/src/test/java/io/netty/resolver/dns/DnsAddressResolverGroupTest.java +++ b/resolver-dns/src/test/java/io/netty/resolver/dns/DnsAddressResolverGroupTest.java @@ -79,18 +79,18 @@ public void testSharedDNSCacheAcrossEventLoops() throws InterruptedException, Ex DnsNameResolverBuilder builder = new DnsNameResolverBuilder() .eventLoop(loop).channelType(NioDatagramChannel.class); DnsAddressResolverGroup resolverGroup = new DnsAddressResolverGroup(builder); - - DefaultEventLoopGroup defaultEventLoopGroup = new DefaultEventLoopGroup(2); EventLoop eventLoop1 = defaultEventLoopGroup.next(); EventLoop eventLoop2 = defaultEventLoopGroup.next(); try { final Promise promise1 = loop.newPromise(); InetSocketAddressResolver resolver1 = (InetSocketAddressResolver) resolverGroup.getResolver(eventLoop1); - InetAddress address1 = resolve(resolver1, InetSocketAddress.createUnresolved("netty.io", 80), promise1); + InetAddress address1 = + resolve(resolver1, InetSocketAddress.createUnresolved("netty.io", 80), promise1); final Promise promise2 = loop.newPromise(); InetSocketAddressResolver resolver2 = (InetSocketAddressResolver) resolverGroup.getResolver(eventLoop2); - InetAddress address2 = resolve(resolver2, InetSocketAddress.createUnresolved("netty.io", 80), promise2); + InetAddress address2 = + resolve(resolver2, InetSocketAddress.createUnresolved("netty.io", 80), promise2); assertSame(address1, address2); } finally { resolverGroup.close(); @@ -100,7 +100,8 @@ public void testSharedDNSCacheAcrossEventLoops() throws InterruptedException, Ex } private InetAddress resolve(InetSocketAddressResolver resolver, SocketAddress socketAddress, - final Promise promise) throws InterruptedException, ExecutionException { + final Promise promise) + throws InterruptedException, ExecutionException { resolver.resolve(socketAddress) .addListener(new FutureListener() { @Override