diff --git a/transport-sctp/src/main/java/io/netty/channel/sctp/SctpWorker.java b/transport-sctp/src/main/java/io/netty/channel/sctp/SctpWorker.java index 11bc71cdd7..8b998e44da 100644 --- a/transport-sctp/src/main/java/io/netty/channel/sctp/SctpWorker.java +++ b/transport-sctp/src/main/java/io/netty/channel/sctp/SctpWorker.java @@ -45,6 +45,7 @@ import java.nio.channels.CancelledKeyException; import java.nio.channels.ClosedChannelException; import java.nio.channels.ClosedSelectorException; import java.nio.channels.SelectionKey; +import java.nio.channels.Selector; import java.util.Queue; import java.util.Set; import java.util.concurrent.Executor; @@ -68,6 +69,8 @@ public class SctpWorker extends NioWorker { @Override public void registerWithWorker(final Channel channel, final ChannelFuture future) { + final Selector selector = start(); + try { if (channel instanceof SctpServerChannelImpl) { final SctpServerChannelImpl ch = (SctpServerChannelImpl) channel;