Akka Stream - Timer или Scheduler, как CRON

Question

Я использую Akka Stream на Scala. Я хотел бы установить планировщик, который запускается каждые 24:00. Я попытался найти его. Но я не мог найти то, что хочу. Не могли бы вы рассказать мне, как писать код?

Answer 1

используйте сборки в Акко планировщиком, см: http://doc.akka.io/docs/akka/current/scala/scheduler.html

Вы можете использовать планировщик, как:

system.scheduler.schedule(
    initialDelay = FiniteDuration(/*offset to next 24:00*/), 
    interval = FiniteDuration(24, TimeUnit.HOURS), 
    receiver = self, 
    message = ScheduleAkkaStream 
) 

Тогда в актере, когда ScheduleAkkaStream получено, выполнить задание

Answer 2

Наиболее часто используется один Akka кварцевый планировщик: https://github.com/enragedginger/akka-quartz-scheduler

Это одна написана мной и не имеет никаких дополнительных зависимостей, немного более легкий, чем при использовании кварца с меньшим количеством наворотов: https://github.com/johanandren/akron