Examples of org.quartz.Scheduler.start()

org.quartz.Scheduler.start()

Starts the Scheduler's threads that fire {@link Trigger}s. When a scheduler is first created it is in "stand-by" mode, and will not fire triggers. The scheduler can also be put into stand-by mode by calling the standby() method.

The misfire/recovery process will be started, if it is the initial call to this method on this scheduler instance.
@throws SchedulerException if shutdown() has been called, or there is an error within the Scheduler. @see #startDelayed(int) @see #standby() @see #shutdown()

            properties.put(StdSchedulerFactory.PROP_THREAD_POOL_CLASS, SystemInstance.get().hasProperty(QUARTZ_THREAD_POOL_ADAPTER) ? SystemInstance.get().getOptions().get(QUARTZ_THREAD_POOL_ADAPTER, "")
                    : DefaultTimerThreadPoolAdapter.class.getName());
            properties.put(StdSchedulerFactory.PROP_SCHED_INSTANCE_NAME, "OpenEJB-TimerService-Scheduler");
            try {
                scheduler = new StdSchedulerFactory(properties).getScheduler();
                scheduler.start();
                //durability is configured with true, which means that the job will be kept in the store even if no trigger is attached to it.
                //Currently, all the EJB beans share with the same job instance
                JobDetail job = JobBuilder.newJob(EjbTimeoutJob.class)
                        .withIdentity(OPENEJB_TIMEOUT_JOB_NAME, OPENEJB_TIMEOUT_JOB_GROUP_NAME)
                        .storeDurably(true)

View Full Code Here

   **************************************************************************/
  @SuppressWarnings("deprecation")
  private static void startTimedJobs() throws SchedulerException {
    SchedulerFactory schedFact = new org.quartz.impl.StdSchedulerFactory();
    Scheduler sched = schedFact.getScheduler();
    sched.start();
    
    initializeJob(new HistoryAnalyserJob(), "dailyHistoryAnalyser", sched);
    initializeJobNonConfigured(new HotfolderJob(), 5, sched);
  }

View Full Code Here

            }
            final Scheduler scheduler ;
            try
            {
                scheduler = new StdSchedulerFactory(defaultProperties).getScheduler();
                scheduler.start() ;
            }
            catch (final SchedulerException se)
            {
                throw new SchedulingException("Failed to initialise the scheduler", se) ;
            }

View Full Code Here

        }
        final Scheduler scheduler ;
        try
        {
            scheduler = new StdSchedulerFactory(properties).getScheduler();
            scheduler.start() ;
        }
        catch (final SchedulerException se)
        {
            throw new JbpmException("Failed to initialise the scheduler", se) ;
        }

View Full Code Here

            properties.put(StdSchedulerFactory.PROP_THREAD_POOL_CLASS, SystemInstance.get().hasProperty(QUARTZ_THREAD_POOL_ADAPTER) ? SystemInstance.get().getProperty(QUARTZ_THREAD_POOL_ADAPTER)
                    : DefaultTimerThreadPoolAdapter.class.getName());
            properties.put(StdSchedulerFactory.PROP_SCHED_INSTANCE_NAME, "OpenEJB-TimerService-Scheduler");
            try {
                scheduler = new StdSchedulerFactory(properties).getScheduler();
                scheduler.start();
                //durability is configured with true, which means that the job will be kept in the store even if no trigger is attached to it.
                //Currently, all the EJB beans share with the same job instance
                scheduler.addJob(new JobDetail(OPENEJB_TIMEOUT_JOB_NAME, OPENEJB_TIMEOUT_JOB_GROUP_NAME, EjbTimeoutJob.class, false, true, false), true);
            } catch (SchedulerException e) {
                throw new RuntimeException("Fail to initialize the default scheduler", e);

View Full Code Here


        StdSchedulerFactory factory = new StdSchedulerFactory();
        factory.initialize(schedulerConfig);


        Scheduler scheduler = factory.getScheduler();
        scheduler.start();


        this.nonClusteredSchedulerFactory = factory;
        return;
    }

View Full Code Here

    Scheduler sched = null;
    
      try {
        ssf = new StdSchedulerFactory();
      sched = ssf.getScheduler();
      sched.start();
    } catch (SchedulerException e) {
      e.printStackTrace();
    }
    
    try {

View Full Code Here


            Scheduler scheduler = getScheduler();


            scheduler.scheduleJob(detail, trigger);
            if (schedulerImplicitlyCreated) {
                scheduler.start();
                if (log.isDebugEnabled()) {
                    log.debug("Successfully started implicitly created Quartz Scheduler instance.");
                }
            }
            this.enabled = true;

View Full Code Here

    schedulerControl.setReturnValue(new Date());
    scheduler.addJob(jobDetail1, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger1);
    schedulerControl.setReturnValue(new Date());
    scheduler.start();
    schedulerControl.setVoidCallable();
    scheduler.shutdown(false);
    schedulerControl.setVoidCallable();
    schedulerControl.replay();

View Full Code Here

    }
    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setReturnValue(new Date());
    scheduler.start();
    schedulerControl.setVoidCallable();
    scheduler.shutdown(false);
    schedulerControl.setVoidCallable();
    schedulerControl.replay();

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.