akka-persistence

1Hitze

2Antwort

Akka readJournalPluginId für inmem journal plugin

Welche readJournalPluginId soll ich mit inmem journal plugin verwenden? "akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem" PersistenceQuery(system).readJournalFor[???](???)

7Hitze

2Antwort

Akka Persistence Query Ereignisstrom und CQRS

Ich versuche, Lese-Seite in meiner ES-CQRS-Architektur zu implementieren. Lassen Sie sich sagen, dass ich einen persistenten Schauspieler wie diese: object UserWrite { sealed trait UserEvent

2Hitze

1Antwort

Best Practice Akka Persistenz zu validieren Befehle

Lassen Sie uns sagen, haben wir einen Befehl AddUser: case class AddUser(username: String, password: String) Was wäre der beste Weg, um diesen Befehl zu validieren, bevor Sie ein Ereignis bestehen?

2Hitze

1Antwort

Akka beharrt auf Wiederherstellung abgeschlossene Updates Zustand nach der ersten Nachricht

Ich habe einen persistenten Akteur. Wenn es zum ersten Mal startet (Datenbank ist leer), behalte ich einige Anfangsdaten bei. Aber der Staat wird nicht aktualisiert, wie ich es erwarten würde. Es wird

0Hitze

1Antwort

Ist es möglich, Akka Persistence Journal auf allen Schauspielern zu wiederholen?

Ich habe ein Akka Persistence Journal und mehrere Datenbanken, die unterschiedliche Ansichten der im Journal gespeicherten Daten bieten. Die meisten Ansichten enthalten mehrere Entitäten (-> mehrere P

1Hitze

1Antwort

Akka Persistence Cassandra: Zeitstempel! = Offset. Oder wie man Ereignisse nur einmal verarbeitet?

Ich erstelle gerade eine ereignisbezogene Anwendung mit Akka Persistence und dem Cassandra Journal Plugin. Ich habe einige Ansichten, die Ereignisse von mehreren Persistenz-IDs erfassen müssen, daher

0Hitze

1Antwort

Wie ein PersistentView Update extern

Nach the docs auszulösen, extern eine Ansicht Update Auslösung sollte wie folgt funktionieren: view ! Update(await = true|false) Senden und Warten scheinen allerdings nicht zu arbeiten: view ! Update(

2Hitze

2Antwort

Wie geht man beim Event Sourcing mit Akka 2.4.x an das Q im CQRS heran?

Gibt es eine gute Möglichkeit, CQRS in Kombination mit Event Sourcing zu verwenden? Eine Möglichkeit, wie ich dies im Command-Handler (eines persistenten Actors) tun konnte, sobald der Befehl in ein E

1Hitze

1Antwort

Akka Persistence - AtLeastOnceDelivery: Wie man eine unbegrenzte Anzahl unbestätigter Nachrichten erhält, ohne den Speicher voll zu haben

Wir verwenden einen dauerhaften Akteur AtLeastOnceDelivery. Wir erhalten eine große Menge unbestätigter Nachrichten und dies verursacht einen OutOfMemoryError, wenn diese Zahl zu groß ist. Gibt es ein

1Hitze

1Antwort

Akka persistente Nachricht (en) löschen

Ich schreibe eine Anwendung, um Ereignisse zu behandeln, die von Geräten ausgelöst werden (1 Million pro Stunde). Einige Ereignisse werden aggregiert (und haben eine lange Zeitspanne (z. B. 48 Stunden