class ActiveSupport::Testing::Parallelization::Worker

def start
  fork do
    set_process_title("(starting)")
    DRb.stop_service
    @queue = DRbObject.new_with_uri(@url)
    @queue.start_worker(@id)
    begin
      after_fork
    rescue => @setup_exception; end
    work_from_queue
  ensure
    set_process_title("(stopping)")
    run_cleanup
    @queue.stop_worker(@id)
  end
end