def generateBulkActors()

in app/com/gu/floodgate/AppComponents.scala [141:148]


  def generateBulkActors(environment: String): ActorRef = {
    val contentSources = contentSourceTable.getAllSync()
    val idList = contentSources.filter(contentSource => contentSource.environment == environment).toList
    pekkoActorSystem.actorOf(
      BulkJobActor.props(idList, runningJobService, reindexService, jobHistoryService),
      s"${environment}-bulk-job"
    )
  }