Skip to content

Commit d52a1a5

Browse files
committed
Merged 19456 into default
2 parents bd9f0c0 + 70a9bee commit d52a1a5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/com/rabbitmq/client/impl/SocketFrameHandler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,8 @@ public SocketFrameHandler(SocketFactory factory,
7474
_host = hostName;
7575
_port = portNumber;
7676
_socket = factory.createSocket(_host, _port);
77+
//disable Nagle's algorithm, for more consistently low latency
78+
_socket.setTcpNoDelay(true);
7779

7880
_inputStream = new DataInputStream(new BufferedInputStream(_socket.getInputStream()));
7981
_outputStream = new DataOutputStream(new BufferedOutputStream(_socket.getOutputStream()));

0 commit comments

Comments
 (0)