Add Channel#confirm_select and #fetch_confirm.

Author: jemc

lib/rabbitmq/channel.rb

@@ -222,6 +222,18 @@ def tx_rollback
       fetch_response :tx_rollback_ok
     end
 
+    ##
+    # Confirm mode operations
+    
+    def confirm_select
+      send_request :confirm_select
+      fetch_response :confirm_select_ok
+    end
+    
+    def fetch_confirm
+      fetch_response [:basic_ack, :basic_nack, :basic_reject]
+    end
+    
     ##
     # Message operations
 

spec/channel_spec.rb

@@ -317,4 +317,23 @@
     res.has_key?(:header).should_not be
   end
 
+  it "can work with publish confirms" do
+    res = subject.confirm_select
+    res[:properties].should be_empty
+    
+    subject.queue_delete("my_queue")
+    subject.queue_declare("my_queue")
+    
+    messages = 100.times.map { |i| "message_#{i}" }
+    messages.each do |message|
+      res = subject.basic_publish(message, "", "my_queue")
+      res.should eq true
+    end
+    
+    loop do
+      res = subject.fetch_confirm
+      fail unless res.fetch(:method) == :basic_ack
+      break if res.fetch(:properties).fetch(:delivery_tag) == 100
+    end
+  end
 end