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:
parent
6689063eef
commit
549546f944
@ -259,7 +259,7 @@ public class OrderedMemoryAwareThreadPoolExecutor extends
|
||||
ChannelStateEvent se = (ChannelStateEvent) e;
|
||||
if (se.getState() == ChannelState.OPEN &&
|
||||
!channel.isOpen()) {
|
||||
childExecutors.remove(channel);
|
||||
removeChildExecutor(key);
|
||||
}
|
||||
}
|
||||
return executor;
|
||||
|
Loading…
Reference in New Issue
Block a user