akka/akka-core

PersistenceTestKitReadJournal should implement EventsByTagQuery

Aberta

#29.803 aberto em 10 de nov. de 2020

Ver no GitHubGuia do colaborador
 (3 comentários) (1 reação) (0 responsável)Scala (3.547 forks)batch import
1 - triagedhelp wantedt:persistencet:testing

Métricas do repositório

Stars
 (13.277 estrelas)
Métricas de merge de PR
 (Mesclagem média 8d 19h) (10 fundiu PRs em 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)

Guia do colaborador

Direção de pesquisa
A issue solicita a implementação da interface EventsByTagQuery nas classes PersistenceTestKitReadJournal em Java e Scala. A implementação atual suporta apenas CurrentEventsByTagQuery. Para resolver, adicione o método eventsByTag às classes de journal de leitura Scaladsl e Javadsl, provavelmente em arquivos como `persistence testkit/src/main/scala/akka/persistence/testkit/query/scaladsl/PersistenceTestKitReadJournal.scala` e o arquivo Java correspondente. A implementação deve seguir o mesmo padrão de currentByTag, mas com um offset e uma fonte que transmite eventos em fluxo. Revise implementações existentes como `PersistenceTestKitReadJournal.currentEventsByTag` para orientação.
Pilha de tecnologia
scala
Domain
backendapi
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
Meio dia
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
ScalaAkka Persistence
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
60