org.quartz.Trigger.getName()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.5k)|赞(0)|评价(0)|浏览(146)

本文整理了Java中org.quartz.Trigger.getName()方法的一些代码示例,展示了Trigger.getName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Trigger.getName()方法的具体详情如下:
包路径:org.quartz.Trigger
类名称:Trigger
方法名:getName

Trigger.getName介绍

[英]Get the name of this Trigger.
[中]获取此Trigger的名称。

代码示例

代码示例来源:origin: javamelody/javamelody

boolean isTriggerPaused(Trigger trigger, Scheduler scheduler) throws SchedulerException {
  return scheduler.getTriggerState(trigger.getName(),
      trigger.getGroup()) == Trigger.STATE_PAUSED;
}

代码示例来源:origin: pl.edu.icm.sedno/sedno-tools

private Trigger getTrigger(String triggerName) {
  for(Trigger t : getAllTriggers()) {
    if (t.getName().equals(triggerName)) {
      return t;
    }
  }
  throw new IllegalArgumentException("Trigger ["+triggerName+"] not found");
}

代码示例来源:origin: com.atlassian.scheduler/atlassian-scheduler-quartz1

void collect(RunMode runMode, final Trigger[] triggers) {
  for (Trigger trigger : triggers) {
    final String jobId = trigger.getName();
    if (jobIdsSeen.add(jobId)) {
      try {
        jobs.add(jobDetailsFactory.buildJobDetails(JobId.of(jobId), trigger, runMode));
      } catch (SchedulerRuntimeException sre) {
        LOG.debug("Unable to reconstruct log details for jobId '{}'", jobId, sre);
      }
    }
  }
}

代码示例来源:origin: pl.edu.icm.sedno/sedno-tools

public void applyStartupPauseConfig() {
  for (Trigger trigger : getAllTriggers()) {
    if (shouldBePaused(trigger)) {
      try {
        getScheduler().pauseTrigger(trigger.getName(), trigger.getGroup());
        logger.info(" pausing trigger: "+ trigger.getName());
      }catch (SchedulerException e) {
        throw new RuntimeException(e);
      }                    
    }
  }
}

代码示例来源:origin: net.bull.javamelody/javamelody-core

boolean isTriggerPaused(Trigger trigger, Scheduler scheduler) throws SchedulerException {
  return scheduler.getTriggerState(trigger.getName(),
      trigger.getGroup()) == Trigger.STATE_PAUSED;
}

代码示例来源:origin: quartz/quartz-all

public Key getKey() {
  if(key == null) {
    key = new Key(getName(), getGroup());
  }
  return key;
}

代码示例来源:origin: com.opensymphony.quartz/com.springsource.org.quartz

public Key getKey() {
  if(key == null) {
    key = new Key(getName(), getGroup());
  }
  return key;
}

代码示例来源:origin: net.sourceforge.kivu4j/utils-job

@Override
public void rescheduleJob(Trigger oldTrg, Trigger newTrg) {
  Assert.notNull(oldTrg, "'oldTrg' must not be null");	
  Assert.notNull(newTrg, "'newTrigger' must not be null");
  
  try {
      logger.info("reschedule trigger " +  newTrg.getFullName());
      
      this.scheduler.rescheduleJob(oldTrg.getName(), oldTrg.getGroup(), newTrg);			
  } catch (SchedulerException e) {
    throw new JobException(e);
  }        
}

代码示例来源:origin: pl.edu.icm.sedno/sedno-tools

private int getTriggerState(Trigger trigger) {
  try {
    return getScheduler().getTriggerState(trigger.getName(), trigger.getGroup());
  }catch (SchedulerException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源:origin: org.apache.camel/camel-quartz

public void pauseJob(Trigger trigger) throws SchedulerException {
  if (isClustered()) {
    // do not pause jobs which are clustered, as we want the jobs to continue running on the other nodes
    LOG.debug("Cannot pause job using trigger: {}/{} as the JobStore is clustered.", trigger.getGroup(), trigger.getName());
  } else {
    LOG.debug("Pausing job using trigger: {}/{}", trigger.getGroup(), trigger.getName());
    getScheduler().pauseTrigger(trigger.getName(), trigger.getGroup());
    getScheduler().pauseJob(trigger.getName(), trigger.getGroup());
  }
  // only decrement job counter if we are successful
  decrementJobCounter(getScheduler());
}

代码示例来源:origin: quartz/quartz-all

public void execute(Connection conn) throws JobPersistenceException {
    Trigger[] triggers = getTriggersForJob(conn, ctxt, jobName, groupName);
    for (int j = 0; j < triggers.length; j++) {
      pauseTrigger(conn, ctxt, triggers[j].getName(), triggers[j].getGroup());
    }
  }
});

代码示例来源:origin: quartz/quartz-all

public void execute(Connection conn) throws JobPersistenceException {
    Trigger[] triggers = getTriggersForJob(conn, ctxt, jobName, groupName);
    for (int j = 0; j < triggers.length; j++) {
      resumeTrigger(conn, ctxt, triggers[j].getName(), triggers[j].getGroup());
    }
  }
});

代码示例来源:origin: org.apache.camel/camel-quartz

@Override
protected String createEndpointUri() {
  return "quartz://" + getTrigger().getGroup() + "/" + getTrigger().getName();
}

代码示例来源:origin: com.opensymphony.quartz/com.springsource.org.quartz

public void execute(Connection conn) throws JobPersistenceException {
    Trigger[] triggers = getTriggersForJob(conn, ctxt, jobName, groupName);
    for (int j = 0; j < triggers.length; j++) {
      resumeTrigger(conn, ctxt, triggers[j].getName(), triggers[j].getGroup());
    }
  }
});

代码示例来源:origin: quartz/quartz-all

public void triggerMisfired(Trigger trigger) {
  if (!getLog().isInfoEnabled()) {
    return;
  } 
  
  Object[] args = {
    trigger.getName(), trigger.getGroup(),
    trigger.getPreviousFireTime(), trigger.getNextFireTime(),
    new java.util.Date(), trigger.getJobName(),
    trigger.getJobGroup()
  };
  getLog().info(MessageFormat.format(getTriggerMisfiredMessage(), args));
}

代码示例来源:origin: com.opensymphony.quartz/com.springsource.org.quartz

public void triggerMisfired(Trigger trigger) {
  if (!getLog().isInfoEnabled()) {
    return;
  } 
  
  Object[] args = {
    trigger.getName(), trigger.getGroup(),
    trigger.getPreviousFireTime(), trigger.getNextFireTime(),
    new java.util.Date(), trigger.getJobGroup(),
    trigger.getJobGroup()
  };
  getLog().info(MessageFormat.format(getTriggerMisfiredMessage(), args));
}

代码示例来源:origin: com.atlassian.scheduler/atlassian-scheduler-quartz1

Quartz1Job(final AbstractSchedulerService schedulerService, final RunMode schedulerRunMode,
      final TriggerFiredBundle bundle) {
  final JobId jobId = JobId.of(bundle.getTrigger().getName());
  this.jobLauncher = new JobLauncher(schedulerService, schedulerRunMode, bundle.getFireTime(), jobId);
}

代码示例来源:origin: com.opensymphony.quartz/com.springsource.org.quartz

public void execute(Connection conn) throws JobPersistenceException {
    String[] jobNames = getJobNames(conn, ctxt, groupName);
    for (int i = 0; i < jobNames.length; i++) {
      Trigger[] triggers = getTriggersForJob(conn, ctxt, jobNames[i], groupName);
      for (int j = 0; j < triggers.length; j++) {
        pauseTrigger(conn, ctxt, triggers[j].getName(), triggers[j].getGroup());
      }
    }
  }
});

代码示例来源:origin: quartz/quartz-all

public void execute(Connection conn) throws JobPersistenceException {
    String[] jobNames = getJobNames(conn, ctxt, groupName);
    for (int i = 0; i < jobNames.length; i++) {
      Trigger[] triggers = getTriggersForJob(conn, ctxt, jobNames[i], groupName);
      for (int j = 0; j < triggers.length; j++) {
        resumeTrigger(conn, ctxt, triggers[j].getName(), triggers[j].getGroup());
      }
    }
  }
});

代码示例来源:origin: com.opensymphony.quartz/com.springsource.org.quartz

public void execute(Connection conn) throws JobPersistenceException {
    String[] jobNames = getJobNames(conn, ctxt, groupName);
    for (int i = 0; i < jobNames.length; i++) {
      Trigger[] triggers = getTriggersForJob(conn, ctxt, jobNames[i], groupName);
      for (int j = 0; j < triggers.length; j++) {
        resumeTrigger(conn, ctxt, triggers[j].getName(), triggers[j].getGroup());
      }
    }
  }
});

相关文章

微信公众号

最新文章

更多