Skip to content

Commit b2653f5

Browse files
author
Jayesh Patel
committed
added timer to fetch job status by polling server + displaying previous and next fire time
1 parent 5d14ec6 commit b2653f5

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

src/main/java/com/javabypatel/demo/service/JobServiceImpl.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -308,12 +308,16 @@ public List<Map<String, Object>> getAllJobs() {
308308
//get job's trigger
309309
List<Trigger> triggers = (List<Trigger>) scheduler.getTriggersOfJob(jobKey);
310310
Date scheduleTime = triggers.get(0).getStartTime();
311-
311+
Date nextFireTime = triggers.get(0).getNextFireTime();
312+
Date lastFiredTime = triggers.get(0).getPreviousFireTime();
313+
312314
Map<String, Object> map = new HashMap<String, Object>();
313315
map.put("jobName", jobName);
314316
map.put("groupName", jobGroup);
315317
map.put("scheduleTime", scheduleTime);
316-
318+
map.put("lastFiredTime", lastFiredTime);
319+
map.put("nextFireTime", nextFireTime);
320+
317321
if(isJobRunning(jobName)){
318322
map.put("jobStatus", "RUNNING");
319323
}else{

ui-app/src/app/scheduler/scheduler.component.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,12 +37,10 @@ export class SchedulerComponent implements OnInit, OnDestroy {
3737
this.setDate();
3838
this.getJobs();
3939

40-
/*
4140
let timer = Observable.timer(2000,3000);
4241
this.jobRefreshTimerSubscription = timer.subscribe(t=>{
4342
this.getJobs();
44-
});
45-
*/
43+
});
4644
}
4745

4846
ngOnDestroy() {

0 commit comments

Comments
 (0)