Passage à PersistentView à partir de PersistentView obsolète

Question

J'utilise Akka Persistence, avec LevelDB comme plugin de stockage, dans une application écrite en Scala. Du côté de la requête, l'implémentation actuelle utilise PersistentView, qui interroge les messages d'un journal de PersistentActor en connaissant simplement l'identifiant de l'acteur.

Maintenant, j'ai appris que PersistentView est obsolète, et on est encouragé à utiliser Persistent Query à la place. Cependant, je n'ai pas trouvé de description complète sur la façon d'adapter le code en utilisant PersistentView pour prendre en charge l'implémentation Persistence Query préférée.

Toute aide serait appréciée!

Answer 1

De la 2.4.x à 2.5.x migration guide:

Suppression des PersistentView

Après avoir été dépréciée depuis longtemps, et remplacé par Persistence QueryPersistentView a été supprimée.

Le type de requête correspondant est EventsByPersistenceId. Il existe plusieurs alternatives pour connecter la source à un acteur correspondant à un acteur précédent PersistentView qui sont documentés dans Integration.

L'acteur consommateur peut être un Actor ou un PersistentActor s'il a besoin de stocker son propre état (par exemple fromSequenceNr offset).

Veuillez noter que Persistence Query n'est plus expérimental/peut-être changer dans Akka 2.5.0, donc vous pouvez le mettre à jour en toute sécurité.