From 9e69268085a1ce5dd34a9639594e44948bae87cd Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 10 Jun 2008 18:29:30 +0000 Subject: QPID-1129: unless otherwise specified, limit the receive buffer size to 64K git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@666259 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpidity/transport/network/mina/MinaHandler.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'qpid/java') diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java index 41ec51b529..c6855e3d48 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java @@ -61,6 +61,7 @@ public class MinaHandler implements IoHandler private static final String DEFAULT_READ_BUFFER_LIMIT = "262144"; /** Default buffer size for pending messages writes */ private static final String DEFAULT_WRITE_BUFFER_LIMIT = "262144"; + private static final int MAX_RCVBUF = 64*1024; private static final Logger log = Logger.get(MinaHandler.class); @@ -226,7 +227,11 @@ public class MinaHandler implements IoHandler if (receiveBufferSize != null && receiveBufferSize > 0) { scfg.setReceiveBufferSize(receiveBufferSize); - } + } + else if (scfg.getReceiveBufferSize() > MAX_RCVBUF) + { + scfg.setReceiveBufferSize(MAX_RCVBUF); + } connector.setWorkerTimeout(0); ConnectFuture cf = connector.connect(address, handler); cf.join(); -- cgit v1.2.1