Skip to content

Commit

Permalink
not need config override
Browse files Browse the repository at this point in the history
  • Loading branch information
Roiocam committed May 29, 2024
1 parent 1a90d8f commit 8cf2ad4
Showing 1 changed file with 2 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,12 +14,9 @@

package org.apache.pekko.persistence.jdbc.query

import com.typesafe.config.{ ConfigValue, ConfigValueFactory }

import scala.concurrent.duration._

abstract class AllPersistenceIdsTest(config: String, configOverrides: Map[String, ConfigValue] = Map.empty)
extends QueryTestSpec(config, configOverrides) {
abstract class AllPersistenceIdsTest(config: String) extends QueryTestSpec(config) {
it should "not terminate the stream when there are not pids" in withActorSystem { implicit system =>
val journalOps = new ScalaJdbcReadJournalOperations(system)
journalOps.withPersistenceIds() { tp =>
Expand Down Expand Up @@ -65,11 +62,4 @@ abstract class AllPersistenceIdsTest(config: String, configOverrides: Map[String
}
}

class H2ScalaAllPersistenceIdsTest
extends AllPersistenceIdsTest("h2-application.conf", H2ScalaAllPersistenceIdsTest.configOverrides) with H2Cleaner

object H2ScalaAllPersistenceIdsTest {
val refreshInterval: FiniteDuration = 100.millis
val configOverrides: Map[String, ConfigValue] =
Map("jdbc-read-journal.refresh-interval" -> ConfigValueFactory.fromAnyRef(refreshInterval.toString()))
}
class H2ScalaAllPersistenceIdsTest extends AllPersistenceIdsTest("h2-application.conf") with H2Cleaner

0 comments on commit 8cf2ad4

Please sign in to comment.