本文整理了Java中org.quartz.Trigger.getFireInstanceId()
方法的一些代码示例,展示了Trigger.getFireInstanceId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Trigger.getFireInstanceId()
方法的具体详情如下:
包路径:org.quartz.Trigger
类名称: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: "
内容来源于网络,如有侵权,请联系作者删除!