Sha256: 16792cfec0bad8fc6f5495f8841b54abd6863e9cc2138ad8579451c6373d114b
Contents?: true
Size: 713 Bytes
Versions: 53
Compression:
Stored size: 713 Bytes
Contents
# 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
Version data entries
53 entries across 53 versions & 1 rubygems