This commit is contained in:
norman 2012-08-27 11:21:05 +02:00
parent 292a186d16
commit 039c7563cf

View File

@ -469,12 +469,11 @@ class NioClientSocketPipelineSink extends AbstractNioChannelSink {
ch.register(newSelector, ops, att); ch.register(newSelector, ops, att);
} catch (ClosedChannelException e) { } catch (ClosedChannelException e) {
// close the Channel if we can't register it // close the Channel if we can't register it
AbstractNioChannel<?> channel = (AbstractNioChannel<?>) att; close(key);
channel.worker.close(channel, succeededFuture(channel));
} }
key.cancel(); key.cancel();
} }
try { try {
// time to close the old selector as everything else is registered to the new one // time to close the old selector as everything else is registered to the new one
selector.close(); selector.close();