1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44
|
# encoding: utf-8
require 'spec_helper'
describe "Server-named", AMQP::Queue do
#
# Environment
#
include EventedSpec::AMQPSpec
default_timeout 5
amqp_before do
@channel = AMQP::Channel.new
end
#
# Examples
#
it "can be declared en masse" do
n = 100
queues = []
n.times do
queues << @channel.queue("", :auto_delete => true)
end
done(2.5) {
queues.size.should == n
# this is RabbitMQ-specific. But it is OK for now. MK.
queues.all? { |q| q.name =~ /^amq.*/ }.should be_true
# no duplicates. MK.
names = queues.map { |q| q.name }
names.uniq.size.should == n
names.uniq.should == names
}
end
end
|