Examples of org.quartz.Scheduler.addJob()

org.quartz.Scheduler.addJob()

Add the given Job to the Scheduler - with no associated Trigger. The Job will be 'dormant' until it is scheduled with a Trigger, or Scheduler.triggerJob() is called for it.

The Job must by definition be 'durable', if it is not, SchedulerException will be thrown.
@throws SchedulerException if there is an internal Scheduler error, or if the Job is not durable, or a Job with the same name already exists, and replace is false.

    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());
    scheduler.scheduleJob(trigger1);
    schedulerControl.setReturnValue(new Date());

View Full Code Here

        data.put( "jelly.script",
                  getBody() );


        detail.setJobDataMap( data );


        sched.addJob( detail,
                      true );
    }
}

View Full Code Here

      jobDetail.setRequestsRecovery(jobRequestRecovery);
      jobDetail.setJobDataMap(jdm);
      jobDetail.setJobClass(jobClass);
      // ADD JOB
      try {
        scheduler.addJob(jobDetail, true);
      } catch (SchedulerException e) {
        SpagoBITracer.major(SpagoBIConstants.NAME_MODULE+"(SCHEDULER)", this.getClass().getName(), 
                           "defineJob", "Error while adding job to the scheduler", e);
        throw e;
      }

View Full Code Here

      JobDetail job = new JobDetail("EnviarAlertaJob",
          Scheduler.DEFAULT_GROUP, EnviarAlertaJob.class);
      CronTrigger trigger = new CronTrigger("EnviarAlertaTrigger",
          Scheduler.DEFAULT_GROUP, "EnviarAlertaJob",
          Scheduler.DEFAULT_GROUP, "0/10 0/5 * * * *");
      sched.addJob(job, true);
      Date ft = sched.scheduleJob(trigger);
      getLog().info(
          job.getFullName() + " Foi programado para funcionar em: "
              + ft + " e repete baseado na expressão: "
              + trigger.getCronExpression());

View Full Code Here

        jobParams.put( RESERVEDMAPKEY_UIPASSPARAM, (Serializable) origJobDetail.getJobDataMap().get(
            RESERVEDMAPKEY_STREAMPROVIDER ) );
      }


      JobDetail jobDetail = createJobDetails( jobKey, jobParams );
      scheduler.addJob( jobDetail, true );
      if ( triggerCalendar != null ) {
        scheduler.addCalendar( jobId.toString(), triggerCalendar, true, true );
        quartzTrigger.setCalendarName( jobId.toString() );
      }
      scheduler.rescheduleJob( jobId, jobKey.getUserName(), quartzTrigger );

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 trigger : getTriggers()) {
            boolean triggerExists = (scheduler.getTrigger(trigger.getName(), trigger.getGroup()) != null);
            if (!triggerExists) {
                try {
                    scheduler.scheduleJob(trigger);

View Full Code Here

                    final JobDetail job = JobBuilder.newJob(EjbTimeoutJob.class)
                                                    .withIdentity(OPENEJB_TIMEOUT_JOB_NAME, OPENEJB_TIMEOUT_JOB_GROUP_NAME)
                                                    .storeDurably(true)
                                                    .requestRecovery(false)
                                                    .build();
                    thisScheduler.addJob(job, true);
                } catch (SchedulerException e) {
                    throw new OpenEJBRuntimeException("Fail to initialize the default scheduler", e);
                }


                if (!newInstance) {

View Full Code Here

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


                if (!newInstance) {

View Full Code Here

            final Scheduler scheduler = this.schedulers.get(schedulerName);
            if (scheduler == null || !scheduler.checkExists(jobKey)) {
                final JobDetail jobDetail = createJobDetail(scheduledJobDetail);
                final String tempSchedulerName = "temp" + scheduledJobDetail.getId();
                final Scheduler tempScheduler = createScheduler(tempSchedulerName, 1, schedulerJobListener, schedulerStopListener);
                tempScheduler.addJob(jobDetail, true);
                jobDataMap.put(SchedulerServiceConstants.SCHEDULER_NAME, tempSchedulerName);
                this.schedulers.put(tempSchedulerName, tempScheduler);
                tempScheduler.triggerJob(jobDetail.getKey(), jobDataMap);
            } else {
                scheduler.triggerJob(jobKey, jobDataMap);

View Full Code Here

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


            if (!newInstance) {

View Full Code Here

0 1 2 3 4

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.