spec/integration/eventmachine/exchange_declare_spec.rb in amq-client-0.7.0.alpha20 vs spec/integration/eventmachine/exchange_declare_spec.rb in amq-client-0.7.0.alpha21
- old
+ new
@@ -92,10 +92,9 @@
channel.on_error do
@error_fired = true
end
exchange = AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout)
exchange.declare(false, false, false, false) do # initial declaration
- exchange.delete
AMQ::Client::Exchange.new(client, channel, exchange_name, :fanout).declare(false) do
@callback_fired = true
end
end
delayed(0.1) { exchange.delete }