void selectJobsToInitialize() {
    for (String queue : jobQueues.keySet()) {
      ArrayList<JobInProgress> jobsToInitialize = getJobsToInitialize(queue);
      printJobs(jobsToInitialize);
      JobInitializationThread t = threadsToQueueMap.get(queue);
      for (JobInProgress job : jobsToInitialize) {
        t.addJobsToQueue(queue, job);
      }
    }
  }
void selectJobsToInitialize ( ) { for ( String queue : jobQueues . keySet ( ) ) { ArrayList < JobInProgress > jobsToInitialize = getJobsToInitialize ( queue ) ; printJobs ( jobsToInitialize ) ; JobInitializationThread t = threadsToQueueMap . get ( queue ) ; for ( JobInProgress job : jobsToInitialize ) { t . addJobsToQueue ( queue , job ) ; } } }
The key method which does selecting jobs to be initalized across
queues and assign those jobs to their appropriate init-worker threads.
<br/>
This method is overriden in test case which is used to test job
initialization poller.