2016-07-20 7 views
1

Ich benutze Akka Stream auf Scala. Ich möchte einen Scheduler einstellen, der auf jeder 24:00 läuft. Ich habe versucht, danach zu suchen. Aber ich konnte nicht finden, was ich machen möchte. Können Sie mir sagen, wie man Code schreibt?Akka Stream - Timer oder Scheduler wie CRON

Antwort

3

verwenden Sie den eingebauten Scheduler Akka finden Sie unter: http://doc.akka.io/docs/akka/current/scala/scheduler.html

Sie den Scheduler verwenden können, wie:

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

Dann in dem Schauspieler, wenn der ScheduleAkkaStream empfangen wird, führen Sie den Job

+0

Vielen Dank! – redstone

Verwandte Themen