logger.debug("TASK SCHEDULER OFF - TASK SCHEDULER OFF - TASK SCHEDULER OFF - TASK SCHEDULER OFF");
if (logger.isInfoEnabled()) logger.info("DemandForecastor TASK SCHEDULER OFF "+ ais.getMessageAddress().toString() + getSupplyType());
  private void setupTaskScheduler() {    String taskScheduler = (String) pluginParams.get(TASK_SCHEDULER_OFF);    turnOffTaskSched = new Boolean(taskScheduler).booleanValue();    QuiescenceReportService qrs = (QuiescenceReportService)      getServiceBroker().getService(this, QuiescenceReportService.class, null);    AgentIdentificationService ais = (AgentIdentificationService)       getServiceBroker().getService(this, AgentIdentificationService.class, null);    qrs.setAgentIdentificationService(ais);    QuiescenceAccumulator q = new QuiescenceAccumulator (qrs);    if (!turnOffTaskSched) {      java.io.InputStream is = null;      try {        is = getConfigFinder().open ("demandSchedPolicy.xml");      } catch (Exception e) {        logger.error ("Could not find file demandSchedPolicy.xml");      }      genProjTaskScheduler = new TaskScheduler        (new GenProjPredicate (supplyType, taskUtils),         TaskSchedulingPolicy.fromXML (is, this, getAlarmService()),         blackboard, q, logger,"GenProjs for " + getBlackboardClientName());    } else {      logger.debug("TASK SCHEDULER OFF - TASK SCHEDULER OFF - TASK SCHEDULER OFF - TASK SCHEDULER OFF");     genProjTaskScheduler = new TaskScheduler      (new GenProjPredicate (supplyType, taskUtils),       new TaskSchedulingPolicy (new TaskSchedulingPolicy.Predicate[]                                     {TaskSchedulingPolicy.PASSALL}),       blackboard, q, logger,"GenProjs for " + getBlackboardClientName());    }  }