akka/akka-core

PersistenceTestKitReadJournal should implement EventsByTagQuery

开放

#29,803 创建于 2020年11月10日

 (3 条评论) (1 个反应) (0 位负责人)Scala (3,547 个派生)batch import
1 - triagedhelp wantedt:persistencet:testing

仓库指标

星标
 (13,277 个星标)
PR 合并指标
 (平均合并 8天 19小时) (30 天内合并 10 个 PR)

描述

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)

贡献者指南