public

ericacm / scheduledDistribute.scala

Last active 2013-01-21

@Value("${deliveryService.distributeSchedule:0,30 * * * * *}")
var distributeSchedule: String = _
 
schedulerService.addJob(
  SchedulerJob("distributeEvents", () => scheduledDistribute(), distributeSchedule))
 
def scheduledDistribute() = 
  if (clusterService.clusterStatus.isLeader)    
    distribute()