gistfile1.rb

class QueueWorker < BackgrounDRb::MetaWorker
  set_worker_name :queue_worker
  QUEUE_WORKER_LIMIT = 2

  def create(args = nil)
    start_correct_number_of_workers
  end

  def start_correct_number_of_workers
    1.upto(QUEUE_WORKER_LIMIT) do |worker_key|
      MiddleMan.new_worker(:worker => :queue_worker, :worker_key => "queue_#{worker_key}")
    end
  end
end