Validation dispatcher

Author: jmarin

validation/src/main/resources/application.conf

@@ -3,6 +3,31 @@ akka {
   loglevel = "OFF"
   log-dead-letters = off
   log-dead-letters-during-shutdown = off
+
+  actor {
+    deployment {
+      /validation-stats {
+        dispatcher = validation-dispatcher
+      }
+    }
+  }
+}
+
+validation-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
 }
 
 hmda {

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

@@ -108,10 +108,6 @@ class ValidationStats extends HmdaPersistentActor {
 
   override def persistenceId: String = s"$name"
 
-  override def preStart(): Unit = {
-    log.info(s"Actor started at ${self.path}")
-  }
-
   var state = ValidationStatsState()
 
   override def updateState(event: Event): Unit = {