We need to set the exception on each MessageEvent. See #293

This commit is contained in:
Norman Maurer 2012-05-01 12:02:47 +02:00
parent ea38734b13
commit b614f81bf7

View File

@ -684,9 +684,10 @@ abstract class AbstractNioWorker implements Worker {
} else {
cause = new ClosedChannelException();
}
evt.getFuture().setFailure(cause);
fireExceptionCaught = true;
}
evt.getFuture().setFailure(cause);
}
}