org.quartz.JobExecutionContext#getScheduledFireTime ( )源码实例Demo

下面列出了org.quartz.JobExecutionContext#getScheduledFireTime ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: lams   文件: JobExecutionContextSupport.java
/**
 * @return composite data
 */
public static CompositeData toCompositeData(JobExecutionContext jec)
        throws SchedulerException {
    try {
        return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
                new Object[] {
                        jec.getScheduler().getSchedulerName(),
                        jec.getTrigger().getKey().getName(),
                        jec.getTrigger().getKey().getGroup(),
                        jec.getJobDetail().getKey().getName(),
                        jec.getJobDetail().getKey().getGroup(),
                        JobDataMapSupport.toTabularData(jec
                                .getMergedJobDataMap()),
                        jec.getTrigger().getCalendarName(),
                        jec.isRecovering(),
                        jec.getRefireCount(),
                        jec.getFireTime(), jec.getScheduledFireTime(),
                        jec.getPreviousFireTime(), jec.getNextFireTime(),
                        jec.getJobRunTime(),
                        jec.getFireInstanceId() });
    } catch (OpenDataException e) {
        throw new RuntimeException(e);
    }
}
 
/**
 * @return composite data
 */
public static CompositeData toCompositeData(JobExecutionContext jec)
		throws SchedulerException {
	try {
		return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
				new Object[] {
						jec.getScheduler().getSchedulerName(),
						jec.getTrigger().getFullName(),
						jec.getJobDetail().getFullName(),
						JobDataMapSupport.toTabularData(jec
								.getMergedJobDataMap()),
						determineCalendarName(jec),
						Boolean.valueOf(jec.isRecovering()),
						Integer.valueOf(jec.getRefireCount()),
						jec.getFireTime(), jec.getScheduledFireTime(),
						jec.getPreviousFireTime(), jec.getNextFireTime(),
						Long.valueOf(jec.getJobRunTime()) });
	} catch (OpenDataException e) {
		throw new RuntimeException(e);
	}
}
 
源代码3 项目: sakai   文件: AutoSubmitAssessmentsJob.java
public void execute(JobExecutionContext jobInfo) throws JobExecutionException {
	loginToSakai("admin");

	String jobName = jobInfo.getJobDetail().getKey().getName();
	String triggerName = jobInfo.getTrigger().getKey().getName();
		Date requestedFire = jobInfo.getScheduledFireTime();
	Date actualfire = jobInfo.getFireTime();

	StringBuffer whoAmI = new StringBuffer("AutoSubmitAssessmentsJob $");
	whoAmI.append(" Job: ");
	whoAmI.append(jobName);
	whoAmI.append(" Trigger: ");
	whoAmI.append(triggerName);
	
	if (requestedFire != null) {
		whoAmI.append(" Fire scheduled: ");
		whoAmI.append(requestedFire.toString());
	}
	
	if (actualfire != null) {
		whoAmI.append(" Fire actual: ");
		whoAmI.append(actualfire.toString());
	}
	
	eventTrackingService.post(eventTrackingService.newEvent(SamigoConstants.EVENT_AUTO_SUBMIT_JOB, safeEventLength(whoAmI.toString()), true));

	log.info("Start Job: {}", whoAmI);
	
	GradingService gradingService = new GradingService();
	int failures = gradingService.autoSubmitAssessments();
	
	if (failures > 0)
	{
		samigoETSProvider.notifyAutoSubmitFailures(failures);
	}
	
	log.info("End Job: {} ({} failures)", whoAmI, failures);
	
	logoutFromSakai();
}
 
源代码4 项目: sakai   文件: AutoSubmitAssessmentsJob.java
public void execute(JobExecutionContext jobInfo) throws JobExecutionException {
	loginToSakai("admin");

	String jobName = jobInfo.getJobDetail().getKey().getName();
	String triggerName = jobInfo.getTrigger().getKey().getName();
		Date requestedFire = jobInfo.getScheduledFireTime();
	Date actualfire = jobInfo.getFireTime();

	StringBuffer whoAmI = new StringBuffer("AutoSubmitAssessmentsJob $");
	whoAmI.append(" Job: ");
	whoAmI.append(jobName);
	whoAmI.append(" Trigger: ");
	whoAmI.append(triggerName);
	
	if (requestedFire != null) {
		whoAmI.append(" Fire scheduled: ");
		whoAmI.append(requestedFire.toString());
	}
	
	if (actualfire != null) {
		whoAmI.append(" Fire actual: ");
		whoAmI.append(actualfire.toString());
	}
	
	eventTrackingService.post(eventTrackingService.newEvent(SamigoConstants.EVENT_AUTO_SUBMIT_JOB, safeEventLength(whoAmI.toString()), true));

	log.info("Start Job: {}", whoAmI);
	
	GradingService gradingService = new GradingService();
	int failures = gradingService.autoSubmitAssessments();
	
	if (failures > 0)
	{
		samigoETSProvider.notifyAutoSubmitFailures(failures);
	}
	
	log.info("End Job: {} ({} failures)", whoAmI, failures);
	
	logoutFromSakai();
}