accomodate broker fudging

Author: rade

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

@@ -40,7 +40,7 @@ public class AMQCommand implements Command {
      * See {@link #checkEmptyContentBodyFrameSize}, an assertion
      * checked at startup.
      */
-    private static final int EMPTY_CONTENT_BODY_FRAME_SIZE = 8;
+    public static final int EMPTY_CONTENT_BODY_FRAME_SIZE = 8;
 
     /** The assembler for this command - synchronised on - contains all the state */
     private final CommandAssembler assembler;

test/src/com/rabbitmq/client/test/functional/FrameMax.java

@@ -29,6 +29,7 @@
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.GetResponse;
 import com.rabbitmq.client.impl.AMQConnection;
+import com.rabbitmq.client.impl.AMQCommand;
 import com.rabbitmq.client.impl.Frame;
 import com.rabbitmq.client.impl.FrameHandler;
 import com.rabbitmq.client.impl.LongStringHelper;
@@ -150,7 +151,9 @@ public GenerousAMQConnection(ConnectionFactory factory,
         }
 
         @Override public int getFrameMax() {
-            return super.getFrameMax() + 1;
+            // the RabbitMQ broker permits frames that are oversize by
+            // up to EMPTY_CONTENT_BODY_FRAME_SIZE octets
+            return super.getFrameMax() + AMQCommand.EMPTY_CONTENT_BODY_FRAME_SIZE + 1;
         }
 
     }