diff --git a/src/main/java/io/vertx/core/net/impl/NetClientImpl.java b/src/main/java/io/vertx/core/net/impl/NetClientImpl.java index 75d084534ff..426f3182898 100644 --- a/src/main/java/io/vertx/core/net/impl/NetClientImpl.java +++ b/src/main/java/io/vertx/core/net/impl/NetClientImpl.java @@ -78,7 +78,7 @@ public class NetClientImpl implements MetricsProvider, NetClient, Closeable { public NetClientImpl(VertxInternal vertx, TCPMetrics metrics, NetClientOptions options, CloseFuture closeFuture) { this.vertx = vertx; - this.channelGroup = new DefaultChannelGroup(vertx.getAcceptorEventLoopGroup().next()); + this.channelGroup = new DefaultChannelGroup(vertx.getAcceptorEventLoopGroup().next(), true); this.options = new NetClientOptions(options); this.sslHelper = new SSLHelper(options, options.getApplicationLayerProtocols()); this.metrics = metrics; diff --git a/src/main/java/io/vertx/core/net/impl/ServerChannelLoadBalancer.java b/src/main/java/io/vertx/core/net/impl/ServerChannelLoadBalancer.java index 2d5b653fd40..52c8bc068c3 100644 --- a/src/main/java/io/vertx/core/net/impl/ServerChannelLoadBalancer.java +++ b/src/main/java/io/vertx/core/net/impl/ServerChannelLoadBalancer.java @@ -40,7 +40,7 @@ class ServerChannelLoadBalancer extends ChannelInitializer { ServerChannelLoadBalancer(EventExecutor executor) { this.workers = new VertxEventLoopGroup(); - this.channelGroup = new DefaultChannelGroup(executor); + this.channelGroup = new DefaultChannelGroup(executor, true); } public VertxEventLoopGroup workers() {