diff --git a/akka-actor/src/main/scala/akka/io/TcpConnection.scala b/akka-actor/src/main/scala/akka/io/TcpConnection.scala index e46d3ccc54..7d64f77db0 100644 --- a/akka-actor/src/main/scala/akka/io/TcpConnection.scala +++ b/akka-actor/src/main/scala/akka/io/TcpConnection.scala @@ -181,7 +181,12 @@ private[io] abstract class TcpConnection(val tcp: TcpExt, val channel: SocketCha def completeConnect(registration: ChannelRegistration, commander: ActorRef, options: immutable.Traversable[SocketOption]): Unit = { // Turn off Nagle's algorithm by default - channel.socket.setTcpNoDelay(true) + try channel.socket.setTcpNoDelay(true) catch { + case e: SocketException ⇒ + // as reported in #16653 some versions of netcat (`nc -z`) doesn't allow setTcpNoDelay + // continue anyway + log.debug("Could not enable TcpNoDelay: {}", e.getMessage) + } options.foreach(_.afterConnect(channel)) commander ! Connected(