| @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