Add Netty channel information on write and flush failure

This commit is contained in:
Yannick Welsch 2017-10-06 09:15:45 +02:00
parent 3176ba418e
commit ec6ea9b403
1 changed files with 2 additions and 1 deletions

View File

@ -322,7 +322,8 @@ public class Netty4Transport extends TcpTransport<Channel> {
} else {
final Throwable cause = f.cause();
Netty4Utils.maybeDie(cause);
logger.warn("write and flush on the network layer failed", cause);
logger.warn((Supplier<?>) () ->
new ParameterizedMessage("write and flush on the network layer failed (channel: [])", channel), cause);
assert cause instanceof Exception;
listener.onFailure((Exception) cause);
}