Add Netty channel information on write and flush failure
@@ -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);
}
