I made my job class to consume data from DB. In addition to this I made the schedule class with interval 1 minutes for test. However the job is not triggering
@Component
@RequiredArgsConstructor
public class OfJob implements Job {
private final OfRepository ofRepository;
private final OfService ofService;
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
List<OfDomain> ofacList = ofRepository.findByPending(true);
ofList.forEach(ofDomain -> {
ofService.evaluate(ofDomain);
});
}
}
Config:
@Component
public class QuartsScheduleConfiguration {
@Bean
public Scheduler scheduler() throws SchedulerException {
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
JobDetail jobDetail = JobBuilder.newJob(OfJob.class).build();
SimpleTrigger simpleTrigger = newTrigger()
.withSchedule(SimpleScheduleBuilder.simpleSchedule().repeatForever().withIntervalInMinutes(1))
.build();
scheduler.scheduleJob(jobDetail, simpleTrigger);
scheduler.start();
return scheduler;
}
}
I have not error on my logs
Help me please