in core/src/main/scala/org/apache/pekko/persistence/jdbc/config/PekkoPersistenceConfig.scala [176:191]
def apply(config: Config): JournalSequenceRetrievalConfig =
JournalSequenceRetrievalConfig(
batchSize = config.getInt("journal-sequence-retrieval.batch-size"),
maxTries = config.getInt("journal-sequence-retrieval.max-tries"),
queryDelay = config.asFiniteDuration("journal-sequence-retrieval.query-delay"),
maxBackoffQueryDelay = config.asFiniteDuration("journal-sequence-retrieval.max-backoff-query-delay"),
askTimeout = config.asFiniteDuration("journal-sequence-retrieval.ask-timeout"))
}
case class JournalSequenceRetrievalConfig(
batchSize: Int,
maxTries: Int,
queryDelay: FiniteDuration,
maxBackoffQueryDelay: FiniteDuration,
askTimeout: FiniteDuration)
class ReadJournalConfig(config: Config) {