Package dev.karlkadak.backend.cron

Class WeatherDataImportScheduler

java.lang.Object

dev.karlkadak.backend.cron.WeatherDataImportScheduler

@Component
public class WeatherDataImportScheduler
extends Object

Used for scheduling the weather data importing using WeatherDataImporter and ThreadPoolTaskScheduler
Also logs the scheduling of imports using Logger

Field Summary

Fields

Modifier and Type	Field	Description
private String	importerCronExpression	Cron expression gathered from application.properties based on which taskScheduler runs WeatherDataImporter.defaultImport
private final Logger	logger
private final org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler	taskScheduler
private final WeatherDataImporter	weatherDataImporter

Constructor Summary

Constructors

Constructor	Description
WeatherDataImportScheduler(org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler, WeatherDataImporter weatherDataImporter, Logger logger)

Method Summary

Modifier and Type	Method	Description
void	scheduleImport()	Initially runs and schedules the WeatherDataImporter.defaultImport method to run using the cron expression specified in application.properties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

taskScheduler

private final org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler

weatherDataImporter

private final WeatherDataImporter weatherDataImporter

logger

private final Logger logger

importerCronExpression

@Value("${importer.cron.expression}")
private String importerCronExpression

Cron expression gathered from application.properties based on which taskScheduler runs WeatherDataImporter.defaultImport

Constructor Details

WeatherDataImportScheduler

@Autowired
public WeatherDataImportScheduler(org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler,
 WeatherDataImporter weatherDataImporter,
 Logger logger)

Method Details

scheduleImport

public void scheduleImport()

Initially runs and schedules the WeatherDataImporter.defaultImport method to run using the cron expression specified in application.properties