FixedRateTask.java

import java.time.Instant;

import com.github.kagkarlsson.scheduler.Scheduler;
import com.github.kagkarlsson.scheduler.task.DeadExecutionHandler;
import com.github.kagkarlsson.scheduler.task.OnStartup;
import com.github.kagkarlsson.scheduler.task.Schedule;
import com.github.kagkarlsson.scheduler.task.Task;

public abstract class FixedRateTask extends Task implements OnStartup {
    public static final String INSTANCE = "fixedRate";

    public FixedRateTask(String name, Schedule schedule) {
        super(name, new OnCompleteRescheduleByPreviousExecution(schedule),
              new DeadExecutionHandler.RescheduleDeadExecution());
    }

    @Override
    public void onStartup(Scheduler scheduler) {
        scheduler.scheduleForExecution(Instant.now(), this.instance(INSTANCE));
    }
}