diff --git a/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala b/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala index 48436b3569..6550753214 100644 --- a/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala +++ b/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala @@ -379,7 +379,11 @@ class NettyTransport(private val settings: NettyTransportSettings, private val s _ ← always(channelGroup.write(ChannelBuffers.buffer(0))) _ ← always({ channelGroup.unbind(); channelGroup.disconnect() }) _ ← always(channelGroup.close()) - } inboundBootstrap.releaseExternalResources() + } { + // Release the selectors, but don't try to kill the dispatcher + if (UseDispatcherForIo.isDefined) inboundBootstrap.shutdown() + else inboundBootstrap.releaseExternalResources() + } }