resque_move_queue.rb

# http://redis.io/commands/rpoplpush

module Resque
  def self.move_queue(source, destination)
    r = Resque.redis
    r.llen("queue:#{source}").times do
      r.rpoplpush("queue:#{source}", "queue:#{destination}")
    end
  end
end

resque_remove_from_queue.rb

module Resque
  def remove_from_queue(queue, match, redis = nil)
    redis ||= Resque.redis
    key = "queue:#{queue}"
    len = redis.llen(key)
    offset = 0
  
    (1...len).each do |n|
      idx = n - offset
      val = redis.lindex(key, idx)
  
      break if val.nil?
  
      next unless val =~ match
  
      redis.lrem(key, 1, val)
      offset += 1
    end
  end
end

resque_share_load.rb

# http://redis.io/commands/rpoplpush

module Resque
  def self.share_load(source, destination, ratio = 0.5)
    r = Resque.redis
    (r.llen("queue:#{source}") * ratio).to_i.times do
      r.rpoplpush("queue:#{source}", "queue:#{destination}")
    end
  end
end