Skip to content

Commit 74a6967

Browse files
author
David R. MacIver
committed
split out default sizes for send and receive
1 parent f3915e7 commit 74a6967

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

src/com/rabbitmq/client/ConnectionFactory.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,8 @@
5252
*/
5353

5454
public class ConnectionFactory {
55-
public static final int DEFAULT_SOCKET_BUFFER_SIZE = 10 * 1024;
55+
public static final int DEFAULT_SOCKET_SEND_BUFFER_SIZE = 10 * 1024;
56+
public static final int DEFAULT_SOCKET_RECEIVE_BUFFER_SIZE = 50 * 1024;
5657

5758
private final ConnectionParameters _params;
5859

@@ -185,10 +186,10 @@ protected void configureSocket(Socket socket) throws IOException{
185186
// equalise the throughput for local traffic. This needs more investigation at to
186187
// how it behaves over a network.
187188

188-
if(socket.getSendBufferSize() < DEFAULT_SOCKET_BUFFER_SIZE)
189-
socket.setSendBufferSize(DEFAULT_SOCKET_BUFFER_SIZE);
190-
if(socket.getReceiveBufferSize() < DEFAULT_SOCKET_BUFFER_SIZE)
191-
socket.setReceiveBufferSize(DEFAULT_SOCKET_BUFFER_SIZE);
189+
if(socket.getSendBufferSize() < DEFAULT_SOCKET_SEND_BUFFER_SIZE)
190+
socket.setSendBufferSize(DEFAULT_SOCKET_SEND_BUFFER_SIZE);
191+
if(socket.getReceiveBufferSize() < DEFAULT_SOCKET_RECEIVE_BUFFER_SIZE)
192+
socket.setReceiveBufferSize(DEFAULT_SOCKET_RECEIVE_BUFFER_SIZE);
192193
}
193194

194195
private Connection newConnection(Address[] addrs,

0 commit comments

Comments
 (0)