Package org.quartz

Examples of org.quartz.Scheduler.addJob()


                JobDetail job = JobBuilder.newJob(EjbTimeoutJob.class)
                        .withIdentity(OPENEJB_TIMEOUT_JOB_NAME, OPENEJB_TIMEOUT_JOB_GROUP_NAME)
                        .storeDurably(true)
                        .requestRecovery(false)
                        .build();
                scheduler.addJob(job, true);
            } catch (SchedulerException e) {
                throw new OpenEJBRuntimeException("Fail to initialize the default scheduler", e);
            }
            SystemInstance.get().setComponent(Scheduler.class, scheduler);
        }
View Full Code Here


        jobDetail.getJobDataMap().put(ServiceMixJob.COMPONENT_NAME, component.getComponentName());
        jobDetail.getJobDataMap().put(ServiceMixJob.ENDPOINT_NAME, EndpointSupport.getKey(this));
        for (Map.Entry<String, Calendar> e : getCalendars().entrySet()) {
            scheduler.addCalendar(e.getKey(), e.getValue(), true, true);
        }
        scheduler.addJob(getJobDetail(), true);
        for (Trigger trg : getTriggers()) {
            boolean triggerExists = scheduler.getTrigger(trg.getName(), trg.getGroup()) != null;
            if (!triggerExists) {
                try {
                    scheduler.scheduleJob(trg);
View Full Code Here

            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);
            }
            SystemInstance.get().setComponent(Scheduler.class, scheduler);
        }
View Full Code Here

    schedulerControl.setReturnValue(null);
    scheduler.getTrigger("myTrigger0", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(null);
    scheduler.getTrigger("myTrigger1", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(null);
    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setReturnValue(new Date());
    scheduler.addJob(jobDetail1, true);
    schedulerControl.setVoidCallable();
View Full Code Here

    schedulerControl.setReturnValue(null);
    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setReturnValue(new Date());
    scheduler.addJob(jobDetail1, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger1);
    schedulerControl.setReturnValue(new Date());
    scheduler.start();
    schedulerControl.setVoidCallable();
View Full Code Here

    scheduler.getTrigger("myTrigger0", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(null);
    scheduler.getTrigger("myTrigger1", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(new SimpleTrigger());
    if (overwrite) {
      scheduler.addJob(jobDetail1, true);
      schedulerControl.setVoidCallable();
      scheduler.rescheduleJob("myTrigger1", Scheduler.DEFAULT_GROUP, trigger1);
      schedulerControl.setReturnValue(new Date());
    }
    else {
View Full Code Here

    }
    else {
      scheduler.getJobDetail("myJob0", Scheduler.DEFAULT_GROUP);
      schedulerControl.setReturnValue(null);
    }
    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setReturnValue(new Date());
    scheduler.start();
    schedulerControl.setVoidCallable();
View Full Code Here

    scheduler.getTrigger("myTrigger0", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(null);
    scheduler.getTrigger("myTrigger1", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(new SimpleTrigger());
    if (overwrite) {
      scheduler.addJob(jobDetail1, true);
      schedulerControl.setVoidCallable();
      scheduler.rescheduleJob("myTrigger1", Scheduler.DEFAULT_GROUP, trigger1);
      schedulerControl.setReturnValue(new Date());
    }
    else {
View Full Code Here

    }
    else {
      scheduler.getJobDetail("myJob0", Scheduler.DEFAULT_GROUP);
      schedulerControl.setReturnValue(null);
    }
    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setThrowable(new ObjectAlreadyExistsException(""));
    if (overwrite) {
      scheduler.rescheduleJob("myTrigger0", Scheduler.DEFAULT_GROUP, trigger0);
View Full Code Here

    schedulerControl.setReturnValue(null);
    scheduler.getTrigger("myTrigger0", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(null);
    scheduler.getTrigger("myTrigger1", Scheduler.DEFAULT_GROUP);
    schedulerControl.setReturnValue(null);
    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.addJob(jobDetail1, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setReturnValue(new Date());
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.