add missing test

remove misleading comments

Author: Alexandru Scvortov

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

@@ -32,7 +32,9 @@
 package com.rabbitmq.client.test.functional;
 
 import com.rabbitmq.client.test.BrokerTestCase;
+import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.AckListener;
+import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.DefaultConsumer;
 import com.rabbitmq.client.GetResponse;
 import com.rabbitmq.client.MessageProperties;
@@ -174,7 +176,6 @@ public void testConfirmBasicRejectRequeue()
         /* wait confirms to go through the broker */
         Thread.sleep(1000);
 
-        /* duplicate confirms mean requeued messages were confirmed */
         channel.basicConsume("confirm-test-noconsumer", true,
                              new DefaultConsumer(channel));
 
@@ -196,13 +197,44 @@ public void testConfirmBasicRecover()
 
         Thread.sleep(1000);
 
-        /* duplicate confirms mean recovered messages were confirmed */
         channel.basicConsume("confirm-test-noconsumer", true,
                              new DefaultConsumer(channel));
 
         waitAcks();
     }
 
+    public void testConfirmSelect()
+        throws IOException
+    {
+        try {
+            Channel ch = connection.createChannel();
+            ch.confirmSelect(false);
+            ch.txSelect();
+            fail();
+        } catch (IOException ioe) {
+            checkShutdownSignal(AMQP.PRECONDITION_FAILED, ioe);
+        }
+        try {
+            Channel ch = connection.createChannel();
+            ch.txSelect();
+            ch.confirmSelect(false);
+            fail();
+        } catch (IOException ioe) {
+            checkShutdownSignal(AMQP.PRECONDITION_FAILED, ioe);
+        }
+        try {
+            Channel ch = connection.createChannel();
+            ch.confirmSelect(true);
+            ch.confirmSelect(false);
+            fail();
+        } catch (IOException ioe) {
+            checkShutdownSignal(AMQP.PRECONDITION_FAILED, ioe);
+        }
+        Channel ch = connection.createChannel();
+        ch.confirmSelect(true);
+        ch.confirmSelect(true);
+    }
+
     /* Publish NUM_MESSAGES persistent messages and wait for
      * confirmations. */
     public void confirmTest(String exchange, String queueName,