Examples of org.quartz.Scheduler.rescheduleJob()

org.quartz.Scheduler.rescheduleJob()

Remove (delete) the {@link org.quartz.Trigger} with the given name, and store the new given one - which must be associated with the same job (the new trigger must have the job name & group specified) - however, the new trigger need not have the same name as the old trigger.
@param triggerName The name of the Trigger to be replaced. @param groupName The group name of the Trigger to be replaced. @param newTrigger The new Trigger to be stored. @return null if a Trigger with the givenname & group was not found and removed from the store, otherwise the first fire time of the newly scheduled trigger.

            boolean triggerExists = scheduler.getTrigger(trg.getName(), trg.getGroup()) != null;
            if (!triggerExists) {
                try {
                    scheduler.scheduleJob(trg);
                } catch (ObjectAlreadyExistsException ex) {
                    scheduler.rescheduleJob(trg.getName(), trg.getGroup(), trg);
                }
            } else {
                scheduler.rescheduleJob(trg.getName(), trg.getGroup(), trg);
            }
        }

View Full Code Here

                    scheduler.scheduleJob(trg);
                } catch (ObjectAlreadyExistsException ex) {
                    scheduler.rescheduleJob(trg.getName(), trg.getGroup(), trg);
                }
            } else {
                scheduler.rescheduleJob(trg.getName(), trg.getGroup(), trg);
            }
        }
        super.start();
    }

View Full Code Here

    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 {
      scheduler.getJobDetail("myJob0", Scheduler.DEFAULT_GROUP);
      schedulerControl.setReturnValue(null);

View Full Code Here

    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 {
      scheduler.getJobDetail("myJob0", Scheduler.DEFAULT_GROUP);
      schedulerControl.setReturnValue(null);

View Full Code Here

    scheduler.addJob(jobDetail0, true);
    schedulerControl.setVoidCallable();
    scheduler.scheduleJob(trigger0);
    schedulerControl.setThrowable(new ObjectAlreadyExistsException(""));
    if (overwrite) {
      scheduler.rescheduleJob("myTrigger0", Scheduler.DEFAULT_GROUP, trigger0);
      schedulerControl.setReturnValue(new Date());
    }
    scheduler.start();
    schedulerControl.setVoidCallable();
    scheduler.shutdown(false);

View Full Code Here

          // schedule trigger 
        try{
          if(!exists) {
            scheduler.scheduleJob(trigger);
          } else {
            scheduler.rescheduleJob(triggerName, triggerGroup, trigger);
          }
        } catch (SchedulerException e) {
          SpagoBITracer.critical(SpagoBIConstants.NAME_MODULE, this.getClass().getName(), 
                       "scheduleJob", "Error while scheduling job ", e);
          throw e;

View Full Code Here

      scheduler.addJob( jobDetail, true );
      if ( triggerCalendar != null ) {
        scheduler.addCalendar( jobId.toString(), triggerCalendar, true, true );
        quartzTrigger.setCalendarName( jobId.toString() );
      }
      scheduler.rescheduleJob( jobId, jobKey.getUserName(), quartzTrigger );
      // if (triggerState != Trigger.STATE_PAUSED) {
      // scheduler.resumeTrigger(jobId, jobKey.getUserName());
      // }
      logger
          .debug( MessageFormat

View Full Code Here

          ( (SimpleTrigger) trigger ).setPreviousFireTime( new Date() );
        } else if ( trigger instanceof CronTrigger ) {
          ( (CronTrigger) trigger ).setPreviousFireTime( new Date() );
        }
        // force the trigger to be updated with the previous fire time
        scheduler.rescheduleJob( jobId, jobKey.getUserName(), trigger );
      }


      scheduler.triggerJob( jobId, jobKey.getUserName() );
    } catch ( org.quartz.SchedulerException e ) {
      throw new SchedulerException( Messages.getInstance().getString(

View Full Code Here

    SchedulerFactory schedulerFactory = QuartzUtil.createSchedulerFactory();
    Scheduler scheduler = QuartzUtil.getScheduler(schedulerFactory);
    Trigger tg = QuartzUtil.getTrigger(scheduler, "mytrigger");
    ((SimpleTrigger)tg).getRepeatCount();
        // reschedule the job
        scheduler.rescheduleJob(new TriggerKey("mytrigger"), tg);
  }


  public static void main(String[] args) throws Exception {
    Test test = new Test();
    test.task();

View Full Code Here

            if (!triggerExists) {
                try {
                    scheduler.scheduleJob(trigger);
                }
                catch (ObjectAlreadyExistsException ex) {
                    scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger);
                }
            } else {
                scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger);
            }
        }

View Full Code Here

0 1 2 3

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.