[FIXED] Akka Stream – Timer oder Scheduler wie CRON

Ausgabe

Ich verwende Akka Stream auf Scala. Ich möchte einen Planer festlegen, der alle 24:00 ausgeführt wird . Ich habe versucht danach zu suchen. Aber ich konnte nicht finden, was ich tun möchte. Können Sie mir sagen, wie man Code schreibt?

Lösung

Verwenden Sie den eingebauten Akka-Scheduler, siehe:
http://doc.akka.io/docs/akka/current/scala/scheduler.html

Sie können den Planer wie folgt verwenden:

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

Führen Sie dann im Akteur den Job aus, wenn der ScheduleAkkaStream empfangen wird

Beantwortet von – Bennie Krijger

Antwort geprüft von – Dawn Plyler (FixError Volunteer)