Sha256: 3f9e01c6356c21061cd792b47e631f4cbe9e4dd075c773d7dd6047f3076f9292
Contents?: true
Size: 1.05 KB
Versions: 17
Compression:
Stored size: 1.05 KB
Contents
require "spec_helper"
describe "Any queue" do
#
# Environment
#
let(:connection) { HotBunnies.connect }
let(:channel) { connection.create_channel }
after :each do
channel.close
connection.close
end
#
# Examples
#
it "can be unbound from amq.fanout" do
exchange = channel.exchange("amq.fanout", :type => :fanout, :durable => true, :auto_delete => false)
queue = channel.queue("", :auto_delete => true)
queue.bind(exchange)
exchange.publish("", :routing_key => queue.name)
queue.get.should_not be_nil
queue.unbind(exchange)
exchange.publish("")
queue.get.should be_nil
end
it "can be unbound from a client-declared exchange" do
exchange = channel.exchange("hot.bunnies.fanout#{Time.now.to_i}", :type => :fanout, :durable => false)
queue = channel.queue("", :auto_delete => true)
queue.bind(exchange)
exchange.publish("", :routing_key => queue.name)
queue.get.should_not be_nil
queue.unbind(exchange)
exchange.publish("")
queue.get.should be_nil
end
end
Version data entries
17 entries across 17 versions & 1 rubygems