ericacm / scheduledDistribute.scala

Last active January 21, 2013


    
    View scheduledDistribute.scala 
  
  
      scheduledDistribute.scala
    
    
        Raw
      
    
    File suppressed. Click to show.
  
  
            1
            2
            3
            4
            5
            6
            7
            8
            9
          
          
            @Value("${deliveryService.distributeSchedule:0,30 * * * * *}")
var distributeSchedule: String = _
 
schedulerService.addJob(
  SchedulerJob("distributeEvents", () => scheduledDistribute(), distributeSchedule))
 
def scheduledDistribute() = 
  if (clusterService.clusterStatus.isLeader)    
    distribute()