added pubAck methods to API

Author: Alexandru Scvortov

src/com/rabbitmq/client/Channel.java

@@ -38,6 +38,7 @@
 import com.rabbitmq.client.AMQP.Queue;
 import com.rabbitmq.client.AMQP.Tx;
 import com.rabbitmq.client.AMQP.Basic;
+import com.rabbitmq.client.AMQP.PubAck;
 import com.rabbitmq.client.AMQP.Channel.FlowOk;
 
 /**
@@ -584,4 +585,21 @@ Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, b
      * @throws java.io.IOException if an error is encountered
      */
     Tx.RollbackOk txRollback() throws IOException;
+
+    /**
+     * Enables publisher acknowledgements on this channel.
+     * @param many determines whether the broker can acknowledge
+     * multiple messages at the same time
+     * @see com.rabbitmq.client.AMQP.PubAck.Select
+     * @throws java.io.IOException if an error is encountered
+     */
+    void pubAckSelect(boolean many) throws IOException;
+
+    /**
+     * Disables publisher acknowledgements on this channel.
+     * @see com.rabbitmq.client.AMQP.PubAck.Deselect
+     * @see com.rabbitmq.client.AMQP.PubAck.DeselectOk
+     * @throws java.io.IOException if an error is encountered
+     */
+    PubAck.DeselectOk pubAckDeselect() throws IOException;
 }

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

@@ -48,6 +48,7 @@
 import com.rabbitmq.client.impl.AMQImpl.Exchange;
 import com.rabbitmq.client.impl.AMQImpl.Queue;
 import com.rabbitmq.client.impl.AMQImpl.Tx;
+import com.rabbitmq.client.impl.AMQImpl.PubAck;
 import com.rabbitmq.utility.Utility;
 
 import java.io.IOException;
@@ -782,6 +783,20 @@ public Tx.RollbackOk txRollback()
         return (Tx.RollbackOk) exnWrappingRpc(new Tx.Rollback()).getMethod();
     }
 
+    /** Public API - {@inheritDoc} */
+    public void pubAckSelect(boolean many)
+        throws IOException
+    {
+        transmit(new PubAck.Select(many));
+    }
+
+    /** Public API - {@inheritDoc} */
+    public PubAck.DeselectOk pubAckDeselect()
+        throws IOException
+    {
+        return (PubAck.DeselectOk) exnWrappingRpc(new PubAck.Deselect()).getMethod();
+    }
+
     /** Public API - {@inheritDoc} */
     public Channel.FlowOk flow(final boolean a) throws IOException {
         return (Channel.FlowOk) exnWrappingRpc(new Channel.Flow() {{active = a;}}).getMethod();