try to fix compile

apache · Feb 9, 2025 · a44e984 · a44e984
1 parent 6219c94
commit a44e984
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/EventsBySliceSpec.scala b/...testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/EventsBySliceSpec.scala
@@ -90,7 +90,8 @@ class EventsBySliceSpec
       PersistenceTestKitReadJournal.Identifier)
 
   private val queriesJava =
-    persistenceQuery.getReadJournalFor(JavaPersistenceTestKitReadJournal.Identifier)
+    persistenceQuery.getReadJournalFor[JavaPersistenceTestKitReadJournal](
+      JavaPersistenceTestKitReadJournal.Identifier)
 
   def setup(persistenceId: String): ActorRef[Command] = {
     val probe = createTestProbe[Done]()

diff --git a/...e-testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/EventsByTagSpec.scala b/...e-testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/EventsByTagSpec.scala
@@ -84,7 +84,8 @@ class EventsByTagSpec
       PersistenceTestKitReadJournal.Identifier)
 
   private val queriesJava =
-    persistenceQuery.getReadJournalFor(JavaPersistenceTestKitReadJournal.Identifier)
+    persistenceQuery.getReadJournalFor[JavaPersistenceTestKitReadJournal](
+      JavaPersistenceTestKitReadJournal.Identifier)
 
   def setup(persistenceId: String, tags: Set[String]): ActorRef[Command] = {
     val probe = createTestProbe[Done]()