File: declare_queues.rb

package info (click to toggle)
rabbitmq-server 4.0.5-8
  • links: PTS, VCS
  • area: main
  • in suites: sid
  • size: 37,972 kB
  • sloc: erlang: 257,835; javascript: 22,466; sh: 3,037; makefile: 2,517; python: 1,966; xml: 646; cs: 335; java: 244; ruby: 212; php: 100; perl: 63; awk: 13
file content (19 lines) | stat: -rw-r--r-- 453 bytes parent folder | download | duplicates (5) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
#!/usr/bin/env ruby
require 'bunny'

queues = ARGV

queues.each do |q|
    split = q.split("/")
    vhost = split[0]
    queue_name = split[1]

    conn = Bunny.new(:host => ENV["BUNNY_HOST"] || "127.0.0.1",
                     :user => ENV["BUNNY_USER"] || "guest",
                     :pass => ENV["BUNNY_PASS"] || "guest",
                     :vhost => vhost)
    conn.start
    ch = conn.create_channel
    ch.queue(queue_name)
    conn.stop
end