Add dispatcher to factory methods

Author: jmarin

publication/src/main/scala/hmda/publication/reports/AggregateAndDisclosureReports.scala

@@ -9,7 +9,7 @@ object AggregateAndDisclosureReports {
   case class GenerateDisclosureByMSAReports(respondentId: String, fipsCode: Int)
   def props(): Props = Props(new AggregateAndDisclosureReports)
   def createAggregateDisclosureReports(system: ActorSystem): ActorRef = {
-    system.actorOf(AggregateAndDisclosureReports.props(), "hmda-aggregate-disclosure")
+    system.actorOf(AggregateAndDisclosureReports.props().withDispatcher("validation-dispatcher"), "hmda-aggregate-disclosure")
   }
 }
 

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"))
   }
 
 }

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"))
   }
 
 }

query/src/main/scala/hmda/query/view/filing/HmdaFilingView.scala

@@ -19,7 +19,7 @@ object HmdaFilingView {
   def props(period: String): Props = Props(new HmdaFilingView(period))
 
   def createHmdaFilingView(system: ActorSystem, period: String): ActorRef = {
-    system.actorOf(HmdaFilingView.props(period), s"$name-$period")
+    system.actorOf(HmdaFilingView.props(period).withDispatcher("query-dispatcher"), s"$name-$period")
   }
 
   case class FilingViewState(size: Long = 0, seqNr: Long = 0L) {

query/src/main/scala/hmda/query/view/institutions/InstitutionView.scala

@@ -25,7 +25,7 @@ object InstitutionView {
   def props(): Props = Props(new InstitutionView)
 
   def createInstitutionView(system: ActorSystem): ActorRef = {
-    system.actorOf(InstitutionView.props(), "institutions-view")
+    system.actorOf(InstitutionView.props().withDispatcher("query-dispatcher"), "institutions-view")
   }
 
   case class InstitutionViewState(institutions: Set[Institution] = Set.empty[Institution], seqNr: Long = 0L) {

validation/src/main/scala/hmda/validation/ValidationStats.scala

@@ -55,7 +55,7 @@ object ValidationStats {
   def props(): Props = Props(new ValidationStats)
 
   def createValidationStats(system: ActorSystem): ActorRef = {
-    system.actorOf(ValidationStats.props(), "validation-stats")
+    system.actorOf(ValidationStats.props().withDispatcher("validation-dispatcher"), "validation-stats")
   }
 
   case class ValidationStatsState(stats: Seq[SubmissionStats] = Nil) {