CassOnMars
diff --git a/‎pom.xml
Lines changed: 0 additions & 1 deletion b/‎pom.xml
Lines changed: 0 additions & 1 deletion
diff --git a/‎src/test/java/com/rabbitmq/client/test/functional/BasicConsume.java
Lines changed: 48 additions & 0 deletions b/‎src/test/java/com/rabbitmq/client/test/functional/BasicConsume.java
Lines changed: 48 additions & 0 deletions
diff --git a/‎src/test/java/com/rabbitmq/client/test/functional/FrameMax.java
Lines changed: 5 additions & 0 deletions b/‎src/test/java/com/rabbitmq/client/test/functional/FrameMax.java
Lines changed: 5 additions & 0 deletions
@@ -385,7 +385,6 @@
                 <include>**/SSLTests.*</include>
                 <include>**/ServerTests.*</include>
                 <include>**/HATests.*</include>
-                <include>**/TestMain.*</include>
               </includes>
             </configuration>
             <executions>
 
@@ -0,0 +1,48 @@
+package com.rabbitmq.client.test.functional;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.DefaultConsumer;
+import com.rabbitmq.client.Envelope;
+import com.rabbitmq.client.test.BrokerTestCase;
+import org.junit.Test;
+
+import java.io.IOException;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+import static org.junit.Assert.assertTrue;
+
+/**
+ *
+ */
+public class BasicConsume extends BrokerTestCase {
+
+    @Test public void basicConsumeOk() throws IOException, InterruptedException {
+        String q = channel.queueDeclare().getQueue();
+        basicPublishPersistent("msg".getBytes("UTF-8"), q);
+        basicPublishPersistent("msg".getBytes("UTF-8"), q);
+
+        CountDownLatch latch = new CountDownLatch(2);
+        channel.basicConsume(q, new CountDownLatchConsumer(channel, latch));
+
+        boolean nbOfExpectedMessagesHasBeenConsumed = latch.await(1, TimeUnit.SECONDS);
+        assertTrue("Not all the messages have been received", nbOfExpectedMessagesHasBeenConsumed);
+    }
+
+    static class CountDownLatchConsumer extends DefaultConsumer {
+
+        private final CountDownLatch latch;
+
+        public CountDownLatchConsumer(Channel channel, CountDownLatch latch) {
+            super(channel);
+            this.latch = latch;
+        }
+
+        @Override
+        public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
+            latch.countDown();
+        }
+    }
+
+}
@@ -16,6 +16,7 @@
 
 package com.rabbitmq.client.test.functional;
 
+import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.fail;
 
 import java.io.IOException;
@@ -50,6 +51,10 @@ public FrameMax() {
         connectionFactory.setRequestedFrameMax(FRAME_MAX);
     }
 
+    @Test public void negotiationOk() {
+        assertEquals(FRAME_MAX, connection.getFrameMax());
+    }
+
     /* Publish a message of size FRAME_MAX.  The broker should split
      * this into two frames before sending back.  Frame content should
      * be less or equal to frame-max - 8. */