summaryrefslogtreecommitdiff
path: root/deps/rabbitmq_auth_backend_oauth2/demo/declare_queues.rb
blob: 9ff2145ccfd49e8c5e88d79d1455dbb021811d7d (plain)
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