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