add stayClosed

This commit is contained in:
Vladimir Krivosheev
2016-06-16 15:24:52 +02:00
parent 0bbb50326b
commit f320c3ef4a
@@ -31,7 +31,7 @@ import java.util.concurrent.TimeUnit;
public final class ChannelRegistrar extends ChannelInboundHandlerAdapter {
private static final Logger LOG = Logger.getInstance(ChannelRegistrar.class);
private final ChannelGroup openChannels = new DefaultChannelGroup(ImmediateEventExecutor.INSTANCE);
private final ChannelGroup openChannels = new DefaultChannelGroup(ImmediateEventExecutor.INSTANCE, true);
private boolean isEventLoopGroupOwner;
public boolean isEmpty() {