File: declare_one_hundred_server_named_queues_spec.rb

package info (click to toggle)
ruby-amqp 1.8.0-1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, bullseye, forky, sid, trixie
  • size: 2,508 kB
  • sloc: ruby: 8,272; sh: 11; makefile: 10
file content (44 lines) | stat: -rw-r--r-- 713 bytes parent folder | download | duplicates (3)
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