Remove a few more uses of the :immediate option

ruby-amqp · Dec 2, 2012 · 93c4196 · 93c4196
1 parent e1e1dee
commit 93c4196
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/spec/integration/coolio/basic_return_spec.rb b/spec/integration/coolio/basic_return_spec.rb
@@ -15,7 +15,7 @@
       coolio_amqp_connect do |client|
         channel = AMQ::Client::Channel.new(client, 1)
         channel.open do
-          queue = AMQ::Client::Queue.new(client, channel).declare(false, false, false, true)
+          queue = AMQ::Client::Queue.new(client, channel).declare(false, false, false, false)
 
           # need to delete the queue manually because we don't start consumption,
           # hence, no auto-delete
@@ -26,7 +26,7 @@
           end
 
           messages.each do |message|
-            exchange.publish(message, AMQ::Protocol::EMPTY_STRING, {}, false, true)
+            exchange.publish(message, AMQ::Protocol::EMPTY_STRING, {}, false, false)
           end
         end
 
@@ -36,4 +36,4 @@
       @returned_messages.should == ["NO_CONSUMERS"] * messages.size
     end
   end
-end
+end
diff --git a/spec/integration/eventmachine/basic_return_spec.rb b/spec/integration/eventmachine/basic_return_spec.rb
@@ -15,7 +15,7 @@
       em_amqp_connect do |client|
         channel = AMQ::Client::Channel.new(client, 1)
         channel.open do
-          queue = AMQ::Client::Queue.new(client, channel).declare(false, false, false, true)
+          queue = AMQ::Client::Queue.new(client, channel).declare(false, false, false, false)
           # need to delete the queue manually because we don't start consumption,
           # hence, no auto-delete
           delayed(0.4) { queue.delete }
@@ -37,4 +37,4 @@
       @returned_messages.should == ["NO_CONSUMERS"] * messages.size
     end
   end
-end
+end
diff --git a/spec/integration/eventmachine/concurrent_basic_publish_spec.rb b/spec/integration/eventmachine/concurrent_basic_publish_spec.rb
@@ -57,7 +57,7 @@
                 30.times do
                   Thread.new do
                     messages.each do |message|
-                      exchange.publish(message, queue.name, {}, false, true)
+                      exchange.publish(message, queue.name, {}, false, false)
                     end
                   end
                 end
@@ -76,4 +76,4 @@
       end # it
     end # context
   end # describe
-end
+end