spec/integration/queue_declaration_spec.rb in amqp-0.8.0.rc13 vs spec/integration/queue_declaration_spec.rb in amqp-0.8.0.rc14

@@ -16,11 +16,11 @@
     @channel = AMQP::Channel.new
   end
 
   after(:all) do
     AMQP.cleanup_state
-    done(0.3)
+    done
   end
 
   #
   # Examples
   #
@@ -30,27 +30,27 @@
       let(:name) { "a queue declared at #{Time.now.to_i}" }
 
       it "declares a new queue with that name" do
         queue = @channel.queue(name)
         queue.name.should == name
-        done(0.3)
+        done
       end
 
       it "caches that queue" do
         queue = @channel.queue(name)
         @channel.queue(name).object_id.should == queue.object_id
-        done(0.3)
+        done
       end
     end # context
 
     context "when queue name is passed on as an empty string" do
       context "and :nowait isn't used" do
         it "uses server-assigned queue name" do
           @channel.queue("") do |queue, *args|
             queue.name.should_not be_empty
             queue.delete
-            done(0.3)
+            done
           end
         end
       end
 
 
@@ -91,11 +91,11 @@
         it "should raise ruby exception" do
           expect {
             @channel.queue(name, different_options)
           }.to raise_error(AMQP::IncompatibleOptionsError)
           @queue.delete
-          done(0.3)
+          done
         end
       end
     end
 
     context "when passive option is used" do
@@ -106,11 +106,11 @@
           original_queue = @channel.queue(name)
           queue          = @channel.queue(name, :passive => true)
 
           queue.should == original_queue
 
-          done(0.3)
+          done
         end # it
       end
 
       context "and queue with given name DOES NOT exist" do
         it "raises an exception" do
@@ -118,11 +118,11 @@
 
           expect {
             exchange = @channel.queue("queue declared at #{Time.now.to_i}", :passive => true)
           }.to raise_error
 
-          done(0.3)
+          done
         end # it
       end # context
     end # context
 
 
@@ -134,10 +134,10 @@
 
         expect {
           @channel.queue("previously.declared.durable.queue", :durable => false)
         }.to raise_error(AMQP::IncompatibleOptionsError)
 
-        done(0.3)
+        done
       end # it
     end # context
   end # describe
 end # describe AMQP