add EventsByTagQuery to JavaDSL PersistenceTestKitReadJournal

apache · Feb 8, 2025 · f154835 · f154835
1 parent 26db908
commit f154835
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...la/org/apache/pekko/persistence/testkit/query/javadsl/PersistenceTestKitReadJournal.scala b/...la/org/apache/pekko/persistence/testkit/query/javadsl/PersistenceTestKitReadJournal.scala
@@ -22,6 +22,7 @@ import pekko.persistence.query.javadsl.{
   CurrentEventsByPersistenceIdQuery,
   CurrentEventsByTagQuery,
   EventsByPersistenceIdQuery,
+  EventsByTagQuery,
   ReadJournal
 }
 import pekko.persistence.query.typed
@@ -38,7 +39,8 @@ final class PersistenceTestKitReadJournal(delegate: scaladsl.PersistenceTestKitR
     with EventsByPersistenceIdQuery
     with CurrentEventsByPersistenceIdQuery
     with CurrentEventsByTagQuery
-    with CurrentEventsBySliceQuery {
+    with CurrentEventsBySliceQuery
+    with EventsByTagQuery {
 
   override def eventsByPersistenceId(
       persistenceId: String,
@@ -62,6 +64,9 @@ final class PersistenceTestKitReadJournal(delegate: scaladsl.PersistenceTestKitR
       offset: Offset): Source[typed.EventEnvelope[Event], NotUsed] =
     delegate.currentEventsBySlices(entityType, minSlice, maxSlice, offset).asJava
 
+  override def eventsByTag(tag: String, offset: Offset): Source[EventEnvelope, NotUsed] =
+    delegate.eventsByTag(tag, offset).asJava
+
   override def sliceForPersistenceId(persistenceId: String): Int =
     delegate.sliceForPersistenceId(persistenceId)