Remove the child Executor with the right method so it will also work

when the channel is not the key.See #175
This commit is contained in:
Norman Maurer 2012-02-03 15:47:34 +01:00
parent 01225b0a52
commit 188f01f317

View File

@ -260,7 +260,7 @@ public class OrderedMemoryAwareThreadPoolExecutor extends
ChannelStateEvent se = (ChannelStateEvent) e; ChannelStateEvent se = (ChannelStateEvent) e;
if (se.getState() == ChannelState.OPEN && if (se.getState() == ChannelState.OPEN &&
!channel.isOpen()) { !channel.isOpen()) {
childExecutors.remove(channel); removeChildExecutor(key);
} }
} }
return executor; return executor;