/**
    * This Source Code Form is subject to the terms of the Mozilla Public
    * License, v. 2.0. If a copy of the MPL was not distributed with this
    * file, You can obtain one at http://mozilla.org/MPL/2.0/.
    *
    * If it is not possible or desirable to put the notice in a particular
    * file, then You may include the notice in a location (such as a LICENSE
    * file in a relevant directory) where a recipient would be likely to look
    * for such a notice.
  
   * 
   */
   
  /*  ---------------------------------------------------------------------------
   *  U.S. Government, Department of the Army
   *  Army Materiel Command
   *  Research Development Engineering Command
   *  Communications Electronics Research Development and Engineering Center
   *  ---------------------------------------------------------------------------
   */
  package org.miloss.fgsms.auxsrv;
  
  import java.util.Date;
  import javax.servlet.ServletContextEvent;
  import javax.servlet.ServletContextListener;
  import org.miloss.fgsms.common.DBSettingsLoader;
  import org.miloss.fgsms.services.interfaces.policyconfiguration.KeyNameValueEnc;
  import org.apache.log4j.Level;
  import org.miloss.fgsms.common.Logger;;
  import org.quartz.*;
  import org.quartz.impl.StdSchedulerFactory;
  
  /**
   * Starts up the HornetQ Agent when the servlet container
   * starts
   *
   * @author AO
   */
  public class HornetQStarter implements ServletContextListener {
  
      private static Scheduler sc;
      static Logger log = Logger.getLogger("fgsms.Aux");
      public static final String JOB_NAME = "HornetQAgent";
      public static final String TRIGGER_NAME = "HornetQAgent Trigger";
  
      public void contextInitialized(ServletContextEvent sce) {
          StartupCheck();
  
      }
  
      protected static void StartupCheck() {
          try {
              JobDetail job = null;
              Trigger triger = null;
              sc = new StdSchedulerFactory().getScheduler(AuxConstants.QUARTZ_SCHEDULER_NAME);
              if (sc == null) {
                  log.fatal("Unable to reference the Quartz instance of " + AuxConstants.QUARTZ_SCHEDULER_NAME + " ensure that it exists and is started. Unable to schedule job for " + JOB_NAME);
              }
  
              KeyNameValueEnc interval = DBSettingsLoader.GetPropertiesFromDB(true, "HornetQAgent", "Interval");
              long intinterval = 30000;
              if (interval != null) {
                  try {
                      intinterval = Long.parseLong(interval.getKeyNameValue().getPropertyValue());
                      if (intinterval < 1000) {
                          intinterval = 1000;
                      }
                  } catch (Exception ex) {
                  }
              }
  
              if (!AuxConstants.QuartzJobExists(JOB_NAME, sc)) {
                  job = new JobDetail(JOB_NAME, AuxConstants.QUARTZ_GROUP_NAME, org.miloss.fgsms.auxsrv.HornetQScheduler.class);
                  job.setRequestsRecovery(true);
                  try {
                      triger = TriggerUtils.makeSecondlyTrigger((int) (intinterval / 1000));
  
                      triger.setStartTime(new Date());
                  } catch (Exception ex) {
                      log.log(Level.WARN, "the configuration parameter for HornetQAgent Iinterval is " + intinterval + " and could not be parsed as an integer. Defaulting to 30 second pings");
                      triger = TriggerUtils.makeSecondlyTrigger(30);
                  }
                  triger.setName(TRIGGER_NAME);
                  triger.setGroup(AuxConstants.QUARTZ_TRIGGER_GROUP_NAME);
                  sc.scheduleJob(job, triger);
                  log.log(Level.INFO, "HornetQAgent added");
  
                  if (sc.isShutdown()) {
                      log.log(Level.WARN, "starting quartz");
                  }
                  sc.start();
              }
          } catch (Exception ex) {
              log.log(Level.WARN, "error scheduling HornetQAgent", ex);
          }
      }
  
      protected static void Unschedule() {
          try {
             Scheduler sc = new StdSchedulerFactory().getScheduler(AuxConstants.QUARTZ_SCHEDULER_NAME);
             sc.deleteJob(JOB_NAME, AuxConstants.QUARTZ_GROUP_NAME);
         } catch (Exception ex) {
             log.log(Level.DEBUG, "Error removing job for " + JOB_NAME, ex);
         }
     }
 
     public void contextDestroyed(ServletContextEvent sce) {
         /*
          * try { sc = new StdSchedulerFactory().getScheduler();
          *
          *
          * sc.unscheduleJob("HornetQAgent", "fgsms Aux Services ");
          * sc.deleteJob("HornetQAgent", "fgsms Aux Services ");
          *
          *
          * log.log(Level.WARN, "Undeploying fgsms Aux Services Succeeded. Jobs
          * removed from Quartz scheduler."); } catch (SchedulerException ex) {
          * log.log(Level.WARN, "error unscheduling smx agent", ex); }
          */
     }
 }