publisher_confirmations_spec.rb in amqp-1.0.0.pre1

- old
+ new

@@ -65,11 +65,27 @@
   amqp_before do
     @channel1 = AMQP::Channel.new
     @channel2 = AMQP::Channel.new
   end
 
+  it 'should increment publisher_index confirming channel' do
+    channel3 = AMQP::Channel.new
+    exchange = channel3.fanout("amqpgem.tests.fanout0", :auto_delete => true)
 
+    channel3.confirm_select
+    channel3.publisher_index.should == 0
+
+    EventMachine.add_timer(0.5) do
+      exchange.publish("Hi")
+    end
+
+    done(2.0) do
+      channel3.publisher_index.should == 1
+    end
+  end
+
+
   context "when messages are transient" do
     context "and routable" do
       it "are confirmed as soon as they arrive on all the queues they were routed to" do
         events   = Array.new
 
@@ -114,10 +130,10 @@
         exchange.on_return do |basic_return, metadata, payload|
           fail "Should never happen"
         end
 
         EventMachine.add_timer(0.5) do
-          exchange.publish("Hi", :persistent => false)
+          exchange.publish("Hi", :persistent => false, :immediately => true)
         end
 
         done(2.0) do
           events.should include(:basic_ack)
           events.should include(:basic_delivery)