private def getSharedDbOrThrow()

in core/src/main/scala/org/apache/pekko/persistence/jdbc/db/SlickExtension.scala [83:95]

• 12 lines of code
• 3 McCabe index (conditional complexity)

  private def getSharedDbOrThrow(sharedDbName: String): LazySlickDatabase =
    sharedDatabases.getOrElse(
      sharedDbName,
      throw new RuntimeException(
        s"No shared database is configured under pekko-persistence-jdbc.shared-databases.$sharedDbName"))

  def database(config: Config): SlickDatabase = {
    config.asStringOption(ConfigKeys.useSharedDb) match {
      case None => SlickDatabase.initializeEagerly(config, new SlickConfiguration(config.getConfig("slick")), "slick")
      case Some(sharedDbName) =>
        getSharedDbOrThrow(sharedDbName)
    }
  }