def start()

in core/src/main/scala/org/apache/pekko/projection/internal/Telemetry.scala [101:118]

• 17 lines of code
• 5 McCabe index (conditional complexity)

  def start(projectionId: ProjectionId, system: ActorSystem[_]): Telemetry = {
    if (!system.settings.config.hasPath("pekko.projection.telemetry.implementations")) {
      NoopTelemetry
    } else {
      val telemetryFqcns: util.List[String] =
        system.settings.config.getStringList("pekko.projection.telemetry.implementations")

      telemetryFqcns.size() match {
        case 0 =>
          NoopTelemetry
        case 1 =>
          val fqcn = telemetryFqcns.get(0)
          create(projectionId, system, fqcn)
        case _ =>
          new EnsembleTelemetry(telemetryFqcns.asScala.toSeq, projectionId, system)
      }
    }
  }