spec/integration/coolio/exchange_declare_spec.rb in amq-client-0.7.0.alpha35 vs spec/integration/coolio/exchange_declare_spec.rb in amq-client-0.8.0

@@ -1,20 +1,22 @@
+# encoding: utf-8
+
 require 'spec_helper'
 require 'integration/coolio/spec_helper'
 
 describe "AMQ::Client::CoolioClient", "Exchange.Declare", :nojruby => true do
   include EventedSpec::SpecHelper
-  default_timeout 1
+  default_timeout 2
   let(:exchange_name) { "amq-client.testexchange.#{Time.now.to_i}" }
   it "should create an exchange and trigger a callback" do
     coolio_amqp_connect do |client|
       channel = AMQ::Client::Channel.new(client, 1)
       channel.open do
         exchange = AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout)
         exchange.declare do
           exchange.delete
-          done(0.2)
+          done(0.5)
         end
       end
     end
   end # it "should create an exchange and trigger a callback"
 
@@ -31,11 +33,11 @@
               exchange = AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout)
               exchange.declare(true, false, false, false) do
                 @callback_fired = true
               end
               delayed(0.1) { exchange.delete }
-              done(0.3)
+              done(0.5)
             end
           end
 
           @callback_fired.should be_false
           @error_fired.should be_true
@@ -53,11 +55,11 @@
                 AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout).declare(true) do
                   @callback_fired = true
                 end
               end
               delayed(0.1) { exchange.delete }
-              done(0.3)
+              done(0.5)
             end
           end
 
           @callback_fired.should be_true
           @error_fired.should be_false
@@ -75,11 +77,11 @@
               exchange = AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout)
               exchange.declare(false, false, false, false) do
                 @callback_fired = true
               end
               delayed(0.1) { exchange.delete }
-              done(0.3)
+              done(0.5)
             end
           end
 
           @callback_fired.should be_true
           @error_fired.should be_false
@@ -97,10 +99,10 @@
                 AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout).declare(false) do
                   @callback_fired = true
                 end
               end
               delayed(0.1) { exchange.delete }
-              done(0.3)
+              done(0.5)
             end
           end
 
           @callback_fired.should be_true
           @error_fired.should be_false