diff --git a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala
index 5a1c1a18c3..55c8d954db 100644
--- a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala
+++ b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala
@@ -9,10 +9,11 @@ import com.typesafe.config.Config
 
 class PersistenceTestKitReadJournalProvider(system: ExtendedActorSystem, config: Config, configPath: String)
     extends ReadJournalProvider {
-
-  override def scaladslReadJournal(): scaladsl.PersistenceTestKitReadJournal =
+  private val _scaladslReadJournal =
     new scaladsl.PersistenceTestKitReadJournal(system, config, configPath)
+  override def scaladslReadJournal(): scaladsl.PersistenceTestKitReadJournal =
+    _scaladslReadJournal
 
   override def javadslReadJournal(): javadsl.PersistenceTestKitReadJournal =
-    new javadsl.PersistenceTestKitReadJournal(scaladslReadJournal())
+    new javadsl.PersistenceTestKitReadJournal(_scaladslReadJournal)
 }
diff --git a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala
index 38d53818df..8270a193ed 100644
--- a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala
+++ b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala
@@ -14,9 +14,10 @@ import akka.persistence.testkit.state.javadsl.{
 }
 
 class PersistenceTestKitDurableStateStoreProvider(system: ExtendedActorSystem) extends DurableStateStoreProvider {
-  private def _scaladslDurableStateStore[T]() = new PersistenceTestKitDurableStateStore[T](system)
-  override def scaladslDurableStateStore(): DurableStateStore[Any] = _scaladslDurableStateStore[Any]()
+  private val _scaladslDurableStateStore = new PersistenceTestKitDurableStateStore[Any](system)
+  override def scaladslDurableStateStore(): DurableStateStore[Any] = _scaladslDurableStateStore
 
   override def javadslDurableStateStore(): JDurableStateStore[AnyRef] =
-    new JPersistenceTestKitDurableStateStore[AnyRef](_scaladslDurableStateStore())
+    new JPersistenceTestKitDurableStateStore[AnyRef](
+      _scaladslDurableStateStore.asInstanceOf[PersistenceTestKitDurableStateStore[AnyRef]])
 }