akka/akka-core
View on GitHubPersistenceTestKitReadJournal should implement EventsByTagQuery
Open
#29,803 opened on Nov 10, 2020
1 - triagedhelp wantedt:persistencet:testing
Repository metrics
- Stars
- (13,277 stars)
- PR merge metrics
- (Avg merge 8d 19h) (10 merged PRs in 30d)
Description
The Java + Scala PersistenceTestKitReadJournal implementations implement CurrentEventsByTagQuery but not EventsByTagQuery which prevent them to be used together when testing Akka Projections.
When trying to use the journal in a test, I receive the following runtime exception:
class akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal cannot be cast to class akka.persistence.query.scaladsl.EventsByTagQuery (akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal and akka.persistence.query.scaladsl.EventsByTagQuery are in unnamed module of loader 'app')
java.lang.ClassCastException: class akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal cannot be cast to class akka.persistence.query.scaladsl.EventsByTagQuery (akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal and akka.persistence.query.scaladsl.EventsByTagQuery are in unnamed module of loader 'app')
at akka.projection.eventsourced.scaladsl.EventSourcedProvider$.eventsByTag(EventSourcedProvider.scala:30)