2016-11-15 3 views
1

Ich möchte unseren Bestellprozess über akka und scala überwachen und ein Aktorsystem aufbauen. Die Nachrichten, die aus dem Webshop kommen, werden in einer mongoDB gespeichert und in 4 verschiedenen Sammlungen gespeichert. jede Sammlung benötigt eine eigene FSM, weil die Reihenfolge verschiedene Zustände in jeder Sammlung hat (z. B. collection1 = Zahlung, collection2 = Lieferung, ...)Datenbank alle X Minuten abfragen

meine Frage ist, wie dieses ganze Akteursystem eingerichtet wird. vor allem muss ich wissen, wie ich mit der MongoDB umgehen, weil ich sehen muss, ob es neue Einträge in der Datenbank alle X Minuten gibt. Diese Abfrage sollte von einem Actor ausgeführt werden, der seine Nachrichten an FSMs sendet. Wie kann ich das erreichen?

ich nicht wirklich etwas auf Google finden (oder ich weiß einfach nicht, was Google: /)

Vielen Dank im Voraus :)

Antwort

0

akka einen Scheduler hat. Sie könnten es verwenden, um die Abfrage jedes X Zeit zu tun: http://doc.akka.io/docs/akka/current/scala/scheduler.html

Weitere (hässlich) Lösung

+0

okay, das ist ein guter Punkt :) wissen Sie, wie ich eine Endlosschleife mit Gewinde Schlaf zu tun wäre, kann sicherstellen, dass nur die hinzugefügten Dokumente seit der letzten Abfrage abgerufen werden? – Chaya93

+0

leider habe ich keine Erfahrung mit mongoDB .. – pedrorijo91

Verwandte Themen