We need to set the exception on each MessageEvent. See #293
This commit is contained in:
parent
2a70df1c1c
commit
b2e77beb46
@ -932,9 +932,10 @@ abstract class AbstractNioWorker implements Worker {
|
||||
} else {
|
||||
cause = new ClosedChannelException();
|
||||
}
|
||||
evt.getFuture().setFailure(cause);
|
||||
fireExceptionCaught = true;
|
||||
}
|
||||
evt.getFuture().setFailure(cause);
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user