reopen http://code.alibabatech.com/jira/browse/DUBBO-600

wangbing4g · Oct 19, 2012 · 2fb8bd5 · 2fb8bd5
1 parent 9754b4d
commit 2fb8bd5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/.../dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/transport/AbstractCodec.java b/.../dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/transport/AbstractCodec.java
@@ -43,9 +43,9 @@ protected Serialization getSerialization(Channel channel) {
     protected static void checkPayload(Channel channel, long size) throws IOException {
         int payload = Constants.DEFAULT_PAYLOAD;
         if (channel != null && channel.getUrl() != null) {
-            payload = channel.getUrl().getPositiveParameter(Constants.PAYLOAD_KEY, Constants.DEFAULT_PAYLOAD);
+            payload = channel.getUrl().getParameter(Constants.PAYLOAD_KEY, Constants.DEFAULT_PAYLOAD);
         }
-        if (size > payload) {
+        if (payload > 0 && size > payload) {
         	IOException e = new IOException("Data length too large: " + size + ", max payload: " + payload + ", channel: " + channel);
         	logger.error(e);
             throw e;
@@ -75,4 +75,4 @@ protected boolean isServerSide(Channel channel) {
 		return !isClientSide(channel);
 	}
 
-}
+}