Sample scheduled job
@Value("${deliveryService.distributeSchedule:0,30 * * * * *}") | |
var distributeSchedule: String = _ | |
schedulerService.addJob( | |
SchedulerJob("distributeEvents", () => scheduledDistribute(), distributeSchedule)) | |
def scheduledDistribute() = | |
if (clusterService.clusterStatus.isLeader) | |
distribute() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment