From bbce8e54eec42ab511d6ab3a130e35202ad1bab1 Mon Sep 17 00:00:00 2001 From: rsujak Date: Thu, 16 Jul 2015 20:19:01 +0200 Subject: [PATCH] Set tcpNoDelay on child channels --- .../main/scala/akka/remote/transport/netty/NettyTransport.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala b/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala index d1d3202c84..2257c64c7e 100644 --- a/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala +++ b/akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala @@ -365,7 +365,7 @@ class NettyTransport(val settings: NettyTransportSettings, val system: ExtendedA private def setupBootstrap[B <: Bootstrap](bootstrap: B, pipelineFactory: ChannelPipelineFactory): B = { bootstrap.setPipelineFactory(pipelineFactory) bootstrap.setOption("backlog", settings.Backlog) - bootstrap.setOption("tcpNoDelay", settings.TcpNodelay) + bootstrap.setOption("child.tcpNoDelay", settings.TcpNodelay) bootstrap.setOption("child.keepAlive", settings.TcpKeepalive) bootstrap.setOption("reuseAddress", settings.TcpReuseAddr) if (isDatagram) bootstrap.setOption("receiveBufferSizePredictorFactory", new FixedReceiveBufferSizePredictorFactory(ReceiveBufferSize.get))