Merge pull request cfpb#1091 from jmarin/dispatchers

schbetsy · web-flow · commit e682f7d6c95b · 2017-08-09T12:53:40.000-04:00
Dispatchers
diff --git a/api/src/main/resources/application.conf b/api/src/main/resources/application.conf
@@ -70,4 +70,21 @@ hmda {
   zookeeperPort = ${?ZOOKEEPER_PORT}
 }
 
+api-dispatcher {
+  type = Dispatcher
+  executor = "fork-join-executor"
+  fork-join-executor {
+    # Min number of threads to cap factor-based parallelism number to
+    parallelism-min = 2
+    # Parallelism (threads) ... ceil(available processors * factor)
+    parallelism-factor = 2.0
+    # Max number of threads to cap factor-based parallelism number to
+    parallelism-max = 10
+  }
+  # Throughput defines the maximum number of messages to be
+  # processed per actor before the thread jumps to the next actor.
+  # Set to 1 for as fair as possible.
+  throughput = 100
+}
+
 
diff --git a/api/src/main/scala/hmda/api/HmdaPlatform.scala b/api/src/main/scala/hmda/api/HmdaPlatform.scala
@@ -34,7 +34,7 @@ object HmdaPlatform {
     val system = ActorSystem(configuration.getString("clustering.name"), configuration)
     val supervisor = createSupervisor(system)
     val querySupervisor = createQuerySupervisor(system)
-    implicit val ec = system.dispatcher
+    implicit val ec = system.dispatchers.lookup("api-dispatcher")
 
     startActors(system, supervisor, querySupervisor)
     startApi(system, querySupervisor)
diff --git a/persistence-model/src/main/scala/hmda/persistence/model/HmdaActor.scala b/persistence-model/src/main/scala/hmda/persistence/model/HmdaActor.scala
@@ -6,6 +6,7 @@ trait HmdaActor extends Actor with ActorLogging {
 
   override def preStart(): Unit = {
     log.info(s"Actor started at ${self.path}")
+    log.info("Thread name for actor: " + Thread.currentThread().getName)
   }
 
   override def postStop(): Unit = {
diff --git a/persistence/src/main/resources/application.conf b/persistence/src/main/resources/application.conf
@@ -1,3 +1,20 @@
 hmda {
   actor-flow-parallelism = 4
 }
+
+persistence-dispatcher {
+  type = Dispatcher
+  executor = "fork-join-executor"
+  fork-join-executor {
+    # Min number of threads to cap factor-based parallelism number to
+    parallelism-min = 2
+    # Parallelism (threads) ... ceil(available processors * factor)
+    parallelism-factor = 2.0
+    # Max number of threads to cap factor-based parallelism number to
+    parallelism-max = 10
+  }
+  # Throughput defines the maximum number of messages to be
+  # processed per actor before the thread jumps to the next actor.
+  # Set to 1 for as fair as possible.
+  throughput = 100
+}
diff --git a/persistence/src/main/scala/hmda/persistence/HmdaSupervisor.scala b/persistence/src/main/scala/hmda/persistence/HmdaSupervisor.scala
@@ -16,7 +16,7 @@ object HmdaSupervisor {
   def props(): Props = Props(new HmdaSupervisor)
 
   def createSupervisor(system: ActorSystem): ActorRef = {
-    system.actorOf(HmdaSupervisor.props(), "supervisor")
+    system.actorOf(HmdaSupervisor.props().withDispatcher("persistence-dispatcher"), "supervisor")
   }
 }
 
@@ -54,47 +54,52 @@ class HmdaSupervisor extends HmdaSupervisorActor {
 
   override def createActor(name: String): ActorRef = name match {
     case id @ SingleLarValidation.name =>
-      val actor = context.actorOf(SingleLarValidation.props, id)
+      val actor = context.actorOf(SingleLarValidation.props.withDispatcher("persistence-dispatcher"), id)
       supervise(actor, id)
     case id @ InstitutionPersistence.name =>
-      val actor = context.actorOf(InstitutionPersistence.props, id)
+      val actor = context.actorOf(InstitutionPersistence.props.withDispatcher("persistence-dispatcher"), id)
       supervise(actor, id)
 
   }
 
   private def createHmdaFiling(filingPeriod: String): ActorRef = {
-    val actor = context.actorOf(HmdaFiling.props(filingPeriod), s"${HmdaFiling.name}-$filingPeriod")
+    val actor = context.actorOf(
+      HmdaFiling.props(filingPeriod).withDispatcher("persistence-dispatcher"),
+      s"${HmdaFiling.name}-$filingPeriod"
+    )
     supervise(actor, HmdaFiling.name)
   }
 
   private def createFilings(name: String, id: String): ActorRef = {
     val filingsId = s"$name-$id"
-    val actor = context.actorOf(FilingPersistence.props(id), filingsId)
+    val actor = context.actorOf(FilingPersistence.props(id).withDispatcher("persistence-dispatcher"), filingsId)
     supervise(actor, filingsId)
   }
 
   private def createSubmissions(name: String, institutionId: String, period: String): ActorRef = {
     val sId = s"$name-$institutionId-$period"
-    val actor = context.actorOf(SubmissionPersistence.props(institutionId, period), sId)
+    val actor = context.actorOf(SubmissionPersistence
+      .props(institutionId, period)
+      .withDispatcher("persistence-dispatcher"), sId)
     supervise(actor, sId)
   }
 
   private def createProcessingActor(name: String, submissionId: SubmissionId): ActorRef = name match {
     case id @ HmdaRawFile.name =>
       val actorId = s"$id-${submissionId.toString}"
-      val actor = context.actorOf(HmdaRawFile.props(submissionId), actorId)
+      val actor = context.actorOf(HmdaRawFile.props(submissionId).withDispatcher("persistence-dispatcher"), actorId)
       supervise(actor, actorId)
     case id @ HmdaFileParser.name =>
       val actorId = s"$id-${submissionId.toString}"
-      val actor = context.actorOf(HmdaFileParser.props(submissionId), actorId)
+      val actor = context.actorOf(HmdaFileParser.props(submissionId).withDispatcher("persistence-dispatcher"), actorId)
       supervise(actor, actorId)
     case id @ HmdaFileValidator.name =>
       val actorId = s"$id-${submissionId.toString}"
-      val actor = context.actorOf(HmdaFileValidator.props(submissionId), actorId)
+      val actor = context.actorOf(HmdaFileValidator.props(submissionId).withDispatcher("persistence-dispatcher"), actorId)
       supervise(actor, actorId)
     case id @ SubmissionManager.name =>
       val actorId = s"$id-${submissionId.toString}"
-      val actor = context.actorOf(SubmissionManager.props(submissionId), actorId)
+      val actor = context.actorOf(SubmissionManager.props(submissionId).withDispatcher("persistence-dispatcher"), actorId)
       supervise(actor, actorId)
   }
 
diff --git a/persistence/src/main/scala/hmda/persistence/institutions/FilingPersistence.scala b/persistence/src/main/scala/hmda/persistence/institutions/FilingPersistence.scala
@@ -18,7 +18,7 @@ object FilingPersistence {
   def props(institutionId: String): Props = Props(new FilingPersistence(institutionId))
 
   def createFilings(institutionId: String, system: ActorSystem): ActorRef = {
-    system.actorOf(FilingPersistence.props(institutionId))
+    system.actorOf(FilingPersistence.props(institutionId).withDispatcher("persistence-dispatcher"))
   }
 
   case class FilingState(filings: Seq[Filing] = Nil) {
diff --git a/persistence/src/main/scala/hmda/persistence/institutions/InstitutionPersistence.scala b/persistence/src/main/scala/hmda/persistence/institutions/InstitutionPersistence.scala
@@ -18,7 +18,7 @@ object InstitutionPersistence {
   def props: Props = Props(new InstitutionPersistence)
 
   def createInstitutions(system: ActorSystem): ActorRef = {
-    system.actorOf(InstitutionPersistence.props, "institutions")
+    system.actorOf(InstitutionPersistence.props.withDispatcher("persistence-dispatcher"), "institutions")
   }
 
   case class InstitutionPersistenceState(institutions: Set[Institution] = Set.empty[Institution]) {
diff --git a/persistence/src/main/scala/hmda/persistence/institutions/SubmissionPersistence.scala b/persistence/src/main/scala/hmda/persistence/institutions/SubmissionPersistence.scala
@@ -19,7 +19,7 @@ object SubmissionPersistence {
   def props(institutionId: String, period: String): Props = Props(new SubmissionPersistence(institutionId, period))
 
   def createSubmissions(institutionId: String, period: String, system: ActorSystem): ActorRef = {
-    system.actorOf(SubmissionPersistence.props(institutionId, period))
+    system.actorOf(SubmissionPersistence.props(institutionId, period).withDispatcher("persistence-dispatcher"))
   }
 
   case class SubmissionState(submissions: Seq[Submission] = Nil) {
diff --git a/persistence/src/main/scala/hmda/persistence/processing/HmdaFileParser.scala b/persistence/src/main/scala/hmda/persistence/processing/HmdaFileParser.scala
@@ -33,7 +33,7 @@ object HmdaFileParser {
   def props(id: SubmissionId): Props = Props(new HmdaFileParser(id))
 
   def createHmdaFileParser(system: ActorSystem, submissionId: SubmissionId): ActorRef = {
-    system.actorOf(HmdaFileParser.props(submissionId))
+    system.actorOf(HmdaFileParser.props(submissionId).withDispatcher("persistence-dispatcher"))
   }
 
   case class PaginatedFileParseState(tsParsingErrors: Seq[String], larParsingErrors: Seq[LarParsingError], totalErroredLines: Int)
diff --git a/persistence/src/main/scala/hmda/persistence/processing/HmdaFileValidator.scala b/persistence/src/main/scala/hmda/persistence/processing/HmdaFileValidator.scala
@@ -51,7 +51,7 @@ object HmdaFileValidator {
   def props(id: SubmissionId): Props = Props(new HmdaFileValidator(id))
 
   def createHmdaFileValidator(system: ActorSystem, id: SubmissionId): ActorRef = {
-    system.actorOf(HmdaFileValidator.props(id))
+    system.actorOf(HmdaFileValidator.props(id).withDispatcher("persistence-dispatcher"))
   }
 
   case class HmdaFileValidationState(
diff --git a/persistence/src/main/scala/hmda/persistence/processing/HmdaFiling.scala b/persistence/src/main/scala/hmda/persistence/processing/HmdaFiling.scala
@@ -26,7 +26,7 @@ object HmdaFiling {
   def props(filingPeriod: String): Props = Props(new HmdaFiling(filingPeriod))
 
   def createHmdaFiling(system: ActorSystem, filingPeriod: String): ActorRef = {
-    system.actorOf(HmdaFiling.props(filingPeriod))
+    system.actorOf(HmdaFiling.props(filingPeriod).withDispatcher("persistence-dispatcher"))
   }
 
 }
diff --git a/persistence/src/main/scala/hmda/persistence/processing/HmdaRawFile.scala b/persistence/src/main/scala/hmda/persistence/processing/HmdaRawFile.scala
@@ -14,7 +14,7 @@ object HmdaRawFile {
   def props(id: SubmissionId): Props = Props(new HmdaRawFile(id))
 
   def createHmdaRawFile(system: ActorSystem, submissionId: SubmissionId): ActorRef = {
-    system.actorOf(HmdaRawFile.props(submissionId))
+    system.actorOf(HmdaRawFile.props(submissionId).withDispatcher("persistence-dispatcher"))
   }
 
   case class AddLine(timestamp: Long, data: String) extends Command
diff --git a/persistence/src/main/scala/hmda/persistence/processing/SingleLarValidation.scala b/persistence/src/main/scala/hmda/persistence/processing/SingleLarValidation.scala
@@ -18,7 +18,7 @@ object SingleLarValidation {
   case object FinishChecks
 
   def createSingleLarValidator(system: ActorSystem): ActorRef = {
-    system.actorOf(SingleLarValidation.props, s"$name")
+    system.actorOf(SingleLarValidation.props.withDispatcher("persistence-dispatcher"), s"$name")
   }
 
 }
diff --git a/persistence/src/main/scala/hmda/persistence/processing/SubmissionManager.scala b/persistence/src/main/scala/hmda/persistence/processing/SubmissionManager.scala
@@ -32,7 +32,7 @@ object SubmissionManager {
   def props(submissionId: SubmissionId): Props = Props(new SubmissionManager(submissionId))
 
   def createSubmissionManager(system: ActorSystem, submissionId: SubmissionId): ActorRef = {
-    system.actorOf(SubmissionManager.props(submissionId))
+    system.actorOf(SubmissionManager.props(submissionId).withDispatcher("persistence-dispatcher"))
   }
 }
 
@@ -47,11 +47,20 @@ class SubmissionManager(submissionId: SubmissionId) extends HmdaActor {
   val supervisor = context.parent
   val hmdaFilingF = (supervisor ? FindHmdaFiling(period)).mapTo[ActorRef]
 
-  val submissionLarStats: ActorRef = context.actorOf(SubmissionLarStats.props(submissionId), s"submission-lar-stats-${submissionId.toString}")
-  val submissionFSM: ActorRef = context.actorOf(SubmissionFSM.props(submissionId))
-  val submissionUpload: ActorRef = context.actorOf(HmdaRawFile.props(submissionId))
-  val submissionParser: ActorRef = context.actorOf(HmdaFileParser.props(submissionId))
-  val submissionValidator: ActorRef = context.actorOf(HmdaFileValidator.props(submissionId))
+  val submissionLarStats: ActorRef = context.actorOf(SubmissionLarStats.props(submissionId)
+    .withDispatcher("persistence-dispatcher"), s"submission-lar-stats-${submissionId.toString}")
+  val submissionFSM: ActorRef = context.actorOf(SubmissionFSM
+    .props(submissionId)
+    .withDispatcher("persistence-dispatcher"))
+  val submissionUpload: ActorRef = context.actorOf(HmdaRawFile
+    .props(submissionId)
+    .withDispatcher("persistence-dispatcher"))
+  val submissionParser: ActorRef = context.actorOf(HmdaFileParser
+    .props(submissionId)
+    .withDispatcher("persistence-dispatcher"))
+  val submissionValidator: ActorRef = context.actorOf(HmdaFileValidator
+    .props(submissionId)
+    .withDispatcher("persistence-dispatcher"))
   val filingPersistence = (supervisor ? FindFilings(FilingPersistence.name, submissionId.institutionId)).mapTo[ActorRef]
 
   var uploaded: Int = 0
diff --git a/publication/src/main/resources/application.conf b/publication/src/main/resources/application.conf
@@ -7,6 +7,11 @@ akka {
 
   actor {
     provider = cluster
+    deployment {
+      /hmda-aggregate-disclosure {
+        dispatcher = publication-dispatcher
+      }
+    }
   }
 
   remote {
@@ -28,22 +33,7 @@ akka {
 
   }
 
-  publication-dispatcher {
-    type = Dispatcher
-    executor = "fork-join-executor"
-    fork-join-executor {
-      # Min number of threads to cap factor-based parallelism number to
-      parallelism-min = 2
-      # Parallelism (threads) ... ceil(available processors * factor)
-      parallelism-factor = 2.0
-      # Max number of threads to cap factor-based parallelism number to
-      parallelism-max = 10
-    }
-    # Throughput defines the maximum number of messages to be
-    # processed per actor before the thread jumps to the next actor.
-    # Set to 1 for as fair as possible.
-    throughput = 100
-  }
+
 
   extensions = ["de.heikoseeberger.constructr.ConstructrExtension"]
 
@@ -66,4 +56,21 @@ hmda {
   zookeeperHost = ${?ZOOKEEPER_HOST}
   zookeeperPort = 2181
   zookeeperPort = ${?ZOOKEEPER_PORT}
+}
+
+publication-dispatcher {
+  type = Dispatcher
+  executor = "fork-join-executor"
+  fork-join-executor {
+    # Min number of threads to cap factor-based parallelism number to
+    parallelism-min = 2
+    # Parallelism (threads) ... ceil(available processors * factor)
+    parallelism-factor = 2.0
+    # Max number of threads to cap factor-based parallelism number to
+    parallelism-max = 10
+  }
+  # Throughput defines the maximum number of messages to be
+  # processed per actor before the thread jumps to the next actor.
+  # Set to 1 for as fair as possible.
+  throughput = 100
 }
diff --git a/publication/src/main/scala/hmda/publication/reports/AggregateAndDisclosureReports.scala b/publication/src/main/scala/hmda/publication/reports/AggregateAndDisclosureReports.scala
@@ -1,18 +1,19 @@
 package hmda.publication.reports
 
-import akka.actor.{ Actor, ActorRef, ActorSystem, Props }
+import akka.actor.{ ActorRef, ActorSystem, Props }
 import akka.stream.ActorMaterializer
+import hmda.persistence.model.HmdaActor
 import hmda.publication.reports.disclosure.DisclosureReports
 
 object AggregateAndDisclosureReports {
   case class GenerateDisclosureByMSAReports(respondentId: String, fipsCode: Int)
   def props(): Props = Props(new AggregateAndDisclosureReports)
   def createAggregateDisclosureReports(system: ActorSystem): ActorRef = {
-    system.actorOf(AggregateAndDisclosureReports.props())
+    system.actorOf(AggregateAndDisclosureReports.props().withDispatcher("validation-dispatcher"), "hmda-aggregate-disclosure")
   }
 }
 
-class AggregateAndDisclosureReports extends Actor {
+class AggregateAndDisclosureReports extends HmdaActor {
 
   import AggregateAndDisclosureReports._
 
diff --git a/publication/src/test/scala/hmda/publication/reports/ReportGenerators.scala b/publication/src/test/scala/hmda/publication/reports/ReportGenerators.scala
@@ -1,7 +1,6 @@
 package hmda.publication.reports
 
 import hmda.model.census.Census
-import hmda.model.publication.reports.MinorityStatusEnum.WhiteNonHispanic
 import hmda.model.publication.reports._
 import org.scalacheck.Gen
 
diff --git a/query/src/main/resources/application.conf b/query/src/main/resources/application.conf
@@ -75,3 +75,20 @@ cassandra {
   retries = 60
   retry-interval = 1000
 }
+
+query-dispatcher {
+  type = Dispatcher
+  executor = "fork-join-executor"
+  fork-join-executor {
+    # Min number of threads to cap factor-based parallelism number to
+    parallelism-min = 2
+    # Parallelism (threads) ... ceil(available processors * factor)
+    parallelism-factor = 2.0
+    # Max number of threads to cap factor-based parallelism number to
+    parallelism-max = 10
+  }
+  # Throughput defines the maximum number of messages to be
+  # processed per actor before the thread jumps to the next actor.
+  # Set to 1 for as fair as possible.
+  throughput = 100
+}
diff --git a/query/src/main/scala/hmda/query/HmdaQuerySupervisor.scala b/query/src/main/scala/hmda/query/HmdaQuerySupervisor.scala
@@ -39,7 +39,7 @@ class HmdaQuerySupervisor extends HmdaSupervisorActor {
 
   override protected def createActor(name: String): ActorRef = name match {
     case id @ InstitutionView.name =>
-      val actor = context.actorOf(InstitutionView.props(), id)
+      val actor = context.actorOf(InstitutionView.props().withDispatcher("query-dispatcher"), id)
       supervise(actor, id)
   }
 
@@ -49,7 +49,7 @@ class HmdaQuerySupervisor extends HmdaSupervisorActor {
 
   private def createHmdaFilingView(period: String)(implicit ec: ExecutionContext): ActorRef = {
     val id = s"${HmdaFilingView.name}-$period"
-    val actor = context.actorOf(HmdaFilingView.props(period), id)
+    val actor = context.actorOf(HmdaFilingView.props(period).withDispatcher("query-dispatcher"), id)
     for {
       p <- (actor ? GetProjectionActorRef).mapTo[ActorRef]
     } yield {
diff --git a/query/src/main/scala/hmda/query/projections/filing/HmdaFilingDBProjection.scala b/query/src/main/scala/hmda/query/projections/filing/HmdaFilingDBProjection.scala
@@ -24,7 +24,7 @@ object HmdaFilingDBProjection extends FilingComponent {
   def props(period: String): Props = Props(new HmdaFilingDBProjection(period))
 
   def createHmdaFilingDBProjection(system: ActorSystem, period: String): ActorRef = {
-    system.actorOf(HmdaFilingDBProjection.props(period))
+    system.actorOf(HmdaFilingDBProjection.props(period).withDispatcher("query-dispatcher"))
   }
 
 }
diff --git a/query/src/main/scala/hmda/query/projections/institutions/InstitutionDBProjection.scala b/query/src/main/scala/hmda/query/projections/institutions/InstitutionDBProjection.scala
@@ -22,7 +22,7 @@ object InstitutionDBProjection extends InstitutionComponent {
   def props(): Props = Props(new InstitutionDBProjection())
 
   def createInstitutionDBProjection(system: ActorSystem): ActorRef = {
-    system.actorOf(InstitutionDBProjection.props())
+    system.actorOf(InstitutionDBProjection.props().withDispatcher("query-dispatcher"))
   }
 
 }
diff --git a/query/src/main/scala/hmda/query/view/filing/HmdaFilingView.scala b/query/src/main/scala/hmda/query/view/filing/HmdaFilingView.scala
diff --git a/query/src/main/scala/hmda/query/view/institutions/InstitutionView.scala b/query/src/main/scala/hmda/query/view/institutions/InstitutionView.scala
diff --git a/validation/src/main/resources/application.conf b/validation/src/main/resources/application.conf
diff --git a/validation/src/main/scala/hmda/validation/ValidationStats.scala b/validation/src/main/scala/hmda/validation/ValidationStats.scala

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@ trait HmdaActor extends Actor with ActorLogging {`
`6`	`6`
`7`	`7`	`override def preStart(): Unit = {`
`8`	`8`	`log.info(s"Actor started at ${self.path}")`
	`9`	`+ log.info("Thread name for actor: " + Thread.currentThread().getName)`
`9`	`10`	`}`
`10`	`11`
`11`	`12`	`override def postStop(): Unit = {`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ object FilingPersistence {`
`18`	`18`	`def props(institutionId: String): Props = Props(new FilingPersistence(institutionId))`
`19`	`19`
`20`	`20`	`def createFilings(institutionId: String, system: ActorSystem): ActorRef = {`
`21`		`- system.actorOf(FilingPersistence.props(institutionId))`
	`21`	`+ system.actorOf(FilingPersistence.props(institutionId).withDispatcher("persistence-dispatcher"))`
`22`	`22`	`}`
`23`	`23`
`24`	`24`	`case class FilingState(filings: Seq[Filing] = Nil) {`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ object InstitutionPersistence {`
`18`	`18`	`def props: Props = Props(new InstitutionPersistence)`
`19`	`19`
`20`	`20`	`def createInstitutions(system: ActorSystem): ActorRef = {`
`21`		`- system.actorOf(InstitutionPersistence.props, "institutions")`
	`21`	`+ system.actorOf(InstitutionPersistence.props.withDispatcher("persistence-dispatcher"), "institutions")`
`22`	`22`	`}`
`23`	`23`
`24`	`24`	`case class InstitutionPersistenceState(institutions: Set[Institution] = Set.empty[Institution]) {`
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ object SubmissionPersistence {`
`19`	`19`	`def props(institutionId: String, period: String): Props = Props(new SubmissionPersistence(institutionId, period))`
`20`	`20`
`21`	`21`	`def createSubmissions(institutionId: String, period: String, system: ActorSystem): ActorRef = {`
`22`		`- system.actorOf(SubmissionPersistence.props(institutionId, period))`
	`22`	`+ system.actorOf(SubmissionPersistence.props(institutionId, period).withDispatcher("persistence-dispatcher"))`
`23`	`23`	`}`
`24`	`24`
`25`	`25`	`case class SubmissionState(submissions: Seq[Submission] = Nil) {`
Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ object HmdaFileParser {`
`33`	`33`	`def props(id: SubmissionId): Props = Props(new HmdaFileParser(id))`
`34`	`34`
`35`	`35`	`def createHmdaFileParser(system: ActorSystem, submissionId: SubmissionId): ActorRef = {`
`36`		`- system.actorOf(HmdaFileParser.props(submissionId))`
	`36`	`+ system.actorOf(HmdaFileParser.props(submissionId).withDispatcher("persistence-dispatcher"))`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`case class PaginatedFileParseState(tsParsingErrors: Seq[String], larParsingErrors: Seq[LarParsingError], totalErroredLines: Int)`
Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,7 @@ object HmdaFileValidator {`
`51`	`51`	`def props(id: SubmissionId): Props = Props(new HmdaFileValidator(id))`
`52`	`52`
`53`	`53`	`def createHmdaFileValidator(system: ActorSystem, id: SubmissionId): ActorRef = {`
`54`		`- system.actorOf(HmdaFileValidator.props(id))`
	`54`	`+ system.actorOf(HmdaFileValidator.props(id).withDispatcher("persistence-dispatcher"))`
`55`	`55`	`}`
`56`	`56`
`57`	`57`	`case class HmdaFileValidationState(`