module Resque::DynamicQueues

def get_job_from_queues(grouped_queues)
  Resque.redis.blpop(grouped_queues, :timeout => (ENV["BLPOP_TIMEOUT"].to_i || 30))
end