public static void enqueueDataCollectionJob(DataCollectionJob job) throws Exception {
  String jobType=job.getType();
  if (jobType.equals(CS_DISCOVERY)) {
    _computeDiscoverJobQueue.put(job);
  }
 else   if (jobType.equals(ARRAYAFFINITY_DISCOVERY)) {
    _arrayAffinityDiscoverJobQueue.put(job);
  }
 else   if (isDiscoveryJobTypeSupported(jobType)) {
    _discoverJobQueue.put(job);
  }
 else   if (jobType.equals(SCANNER)) {
    _scanJobQueue.put(job);
  }
 else   if (jobType.equals(MONITORING)) {
    _monitoringJobQueue.put(job);
  }
 else   if (jobType.equals(METERING)) {
    _meteringJobQueue.put(job);
  }
  _log.info("Queued " + jobType + " job for "+ job.systemString());
}

public static void enqueueDataCollectionJob ( DataCollectionJob job ) throws Exception { String jobType = job . getType ( ) ; if ( jobType . equals ( CS_DISCOVERY ) ) { _computeDiscoverJobQueue . put ( job ) ; } else if ( jobType . equals ( ARRAYAFFINITY_DISCOVERY ) ) { _arrayAffinityDiscoverJobQueue . put ( job ) ; } else if ( isDiscoveryJobTypeSupported ( jobType ) ) { _discoverJobQueue . put ( job ) ; } else if ( jobType . equals ( SCANNER ) ) { _scanJobQueue . put ( job ) ; } else if ( jobType . equals ( MONITORING ) ) { _monitoringJobQueue . put ( job ) ; } else if ( jobType . equals ( METERING ) ) { _meteringJobQueue . put ( job ) ; } _log . info ( "Queued " + jobType + " job for " + job . systemString ( ) ) ; }
queueing discovery job into discovery queue
