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

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

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

Trigger.getFireInstanceId介绍

[英]This method should not be used by the Quartz client.
[中]Quartz客户端不应使用此方法。

代码示例

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

public void jobToBeExecuted(JobExecutionContext context) {
  numJobsFired++;
  synchronized (executingJobs) {
    executingJobs
        .put(context.getTrigger().getFireInstanceId(), context);
  }
}

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

public void jobWasExecuted(JobExecutionContext context,
    JobExecutionException jobException) {
  synchronized (executingJobs) {
    executingJobs.remove(context.getTrigger().getFireInstanceId());
  }
}

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

public void jobToBeExecuted(JobExecutionContext context) {
  numJobsFired++;
  synchronized (executingJobs) {
    executingJobs
        .put(context.getTrigger().getFireInstanceId(), context);
  }
}

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

public void jobWasExecuted(JobExecutionContext context,
    JobExecutionException jobException) {
  synchronized (executingJobs) {
    executingJobs.remove(context.getTrigger().getFireInstanceId());
  }
}

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

try {
  ps = conn.prepareStatement(rtp(INSERT_FIRED_TRIGGER));
  ps.setString(1, trigger.getFireInstanceId());
  ps.setString(2, trigger.getName());
  ps.setString(3, trigger.getGroup());

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

protected void releaseAcquiredTrigger(Connection conn,
    SchedulingContext ctxt, Trigger trigger)
  throws JobPersistenceException {
  try {
    getDelegate().updateTriggerStateFromOtherState(conn,
        trigger.getName(), trigger.getGroup(), STATE_WAITING,
        STATE_ACQUIRED);
    getDelegate().deleteFiredTrigger(conn, trigger.getFireInstanceId());
  } catch (SQLException e) {
    throw new JobPersistenceException(
        "Couldn't release acquired trigger: " + e.getMessage(), e);
  }
}

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

try {
  ps = conn.prepareStatement(rtp(INSERT_FIRED_TRIGGER));
  ps.setString(1, trigger.getFireInstanceId());
  ps.setString(2, trigger.getName());
  ps.setString(3, trigger.getGroup());

代码示例来源:origin: org.terracotta.modules/tim-quartz-1.5.1

public static void recover(TriggerWrapper tw, String instanceId, TreeSet timeTriggers, HashMap jobsByFQN, JobStore jobStore, boolean fireRunningJobsNow) {
  LogFactory.getLog(RAMJobStore.class).info("Recovering job with state " + tw.state + tw.trigger);
  String fireInstanceId = tw.trigger.getFireInstanceId();
  LogFactory.getLog(RAMJobStore.class).info("fireInstanceId = " + fireInstanceId + " instanceId = " + instanceId);
  if(fireInstanceId != null && fireInstanceId.startsWith(instanceId)) {

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

protected void releaseAcquiredTrigger(Connection conn,
    SchedulingContext ctxt, Trigger trigger)
  throws JobPersistenceException {
  try {
    getDelegate().updateTriggerStateFromOtherState(conn,
        trigger.getName(), trigger.getGroup(), STATE_WAITING,
        STATE_ACQUIRED);
    getDelegate().deleteFiredTrigger(conn, trigger.getFireInstanceId());
  } catch (SQLException e) {
    throw new JobPersistenceException(
        "Couldn't release acquired trigger: " + e.getMessage(), e);
  }
}

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

getDelegate().deleteFiredTrigger(conn, trigger.getFireInstanceId());
getDelegate().insertFiredTrigger(conn, trigger, STATE_EXECUTING,
    job);

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

getDelegate().deleteFiredTrigger(conn, trigger.getFireInstanceId());
getDelegate().insertFiredTrigger(conn, trigger, STATE_EXECUTING,
    job);

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

getDelegate().deleteFiredTrigger(conn, trigger.getFireInstanceId());
} catch (SQLException e) {
  throw new JobPersistenceException("Couldn't delete fired trigger: "

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

getDelegate().deleteFiredTrigger(conn, trigger.getFireInstanceId());
} catch (SQLException e) {
  throw new JobPersistenceException("Couldn't delete fired trigger: "

相关文章