org.quartz.SimpleTrigger#getRepeatCount ( )源码实例Demo

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

源代码1 项目： lams 文件： SimpleTriggerSupport.java

public static CompositeData toCompositeData(SimpleTrigger trigger) {
    try {
        return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
                new Object[] {
                        trigger.getRepeatCount(),
                        trigger.getRepeatInterval(),
                        trigger.getTimesTriggered(),
                        trigger.getKey().getName(),
                        trigger.getKey().getGroup(),
                        trigger.getJobKey().getName(),
                        trigger.getJobKey().getGroup(),
                        trigger.getDescription(),
                        JobDataMapSupport.toTabularData(trigger
                                .getJobDataMap()),
                        trigger.getCalendarName(),
                        ((OperableTrigger)trigger).getFireInstanceId(),
                        trigger.getMisfireInstruction(),
                        trigger.getPriority(), trigger.getStartTime(),
                        trigger.getEndTime(), trigger.getNextFireTime(),
                        trigger.getPreviousFireTime(),
                        trigger.getFinalFireTime() });
    } catch (OpenDataException e) {
        throw new RuntimeException(e);
    }
}

源代码2 项目： griffin 文件： SparkSubmitJob.java

private void updateJobInstanceState(JobExecutionContext context)
    throws IOException {
    SimpleTrigger simpleTrigger = (SimpleTrigger) context.getTrigger();
    int repeatCount = simpleTrigger.getRepeatCount();
    int fireCount = simpleTrigger.getTimesTriggered();
    if (fireCount > repeatCount) {
        saveJobInstance(null, NOT_FOUND);
    }
}

源代码3 项目： quartz-manager 文件： SchedulerController.java

@GetMapping("/config")
public SchedulerConfigParam getConfig() {
	log.debug("SCHEDULER - GET CONFIG params");
	SimpleTrigger simpleTrigger = (SimpleTrigger) triggerMonitor.getTrigger();

	int maxCount = simpleTrigger.getRepeatCount() + 1;
	long triggersPerDay = fromMillsIntervalToTriggerPerDay(simpleTrigger.getRepeatInterval());

	return new SchedulerConfigParam(triggersPerDay, maxCount);
}

源代码4 项目： quartz-manager 文件： WebSocketProgressNotifier.java

@Override
public void send() throws SchedulerException {
	TriggerStatus currTriggerStatus = new TriggerStatus();

	Trigger trigger = scheduler.getTrigger(triggerMonitor.getTrigger().getKey());
	currTriggerStatus.setFinalFireTime(trigger.getFinalFireTime());
	currTriggerStatus.setNextFireTime(trigger.getNextFireTime());
	currTriggerStatus.setPreviousFireTime(trigger.getPreviousFireTime());

	int timesTriggered = 0;
	int repeatCount = 0;

	if (trigger instanceof SimpleTrigger) {
		SimpleTrigger simpleTrigger = (SimpleTrigger) trigger;
		timesTriggered = simpleTrigger.getTimesTriggered();
		repeatCount = simpleTrigger.getRepeatCount();
	} else if (trigger instanceof DailyTimeIntervalTrigger) {
		DailyTimeIntervalTrigger dailyTrigger = (DailyTimeIntervalTrigger) trigger;
		timesTriggered = dailyTrigger.getTimesTriggered();
		repeatCount = dailyTrigger.getRepeatCount();
	}

	Trigger jobTrigger = triggerMonitor.getTrigger();
	if (jobTrigger != null && jobTrigger.getJobKey() != null) {
		currTriggerStatus.setJobKey(jobTrigger.getJobKey().getName());
		currTriggerStatus.setJobClass(jobTrigger.getClass().getSimpleName());
		currTriggerStatus.setTimesTriggered(timesTriggered);
		currTriggerStatus.setRepeatCount(repeatCount + 1);
	}

	messagingTemplate.convertAndSend("/topic/progress", currTriggerStatus);
}

方法所在类

org.quartz.SimpleTrigger