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]
|
|
|
|
|
|
2020-03-05 06:21:53 +08:00
|
|
|
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
|
