rabbitmq-server/deps/rabbitmq_auth_backend_oauth2/demo/declare_queues.rb

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

20 lines
453 B
Ruby
Raw Permalink Normal View History

2017-09-20 23:42:42 +08:00
#!/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)
2017-09-20 23:42:42 +08:00
conn.start
ch = conn.create_channel
ch.queue(queue_name)
conn.stop
end