bin/resque in resque-igo-1.12.2 vs bin/resque in resque-igo-1.12.3
- old
+ new
@@ -1,8 +1,9 @@
#!/usr/bin/env ruby
$LOAD_PATH.unshift File.dirname(__FILE__) + '/../lib'
+require 'rubygems'
require 'resque'
def kill(worker)
abort "** resque kill WORKER_ID" if worker.nil?
pid = worker.split(':')[1].to_i
@@ -32,10 +33,16 @@
else
puts "None"
end
end
+def queues
+ Resque.queues.each do |queue|
+ puts"Queue #{queue}: #{Resque.size(queue)}"
+ end
+end
+
if (i = ARGV.index('-r')) && ARGV[i+1]
Resque.redis = ARGV[i+1]
ARGV.delete_at(i)
ARGV.delete_at(i+1)
end
@@ -45,13 +52,16 @@
kill ARGV[1]
when 'remove'
remove ARGV[1]
when 'list'
list
+when 'queues'
+ queues
else
puts "Usage: resque [-r redis_host:redis_port] COMMAND [option]"
puts
puts "Commands:"
puts " remove WORKER Removes a worker"
puts " kill WORKER Kills a worker"
puts " list Lists known workers"
+ puts " queues checks queue depth"
end