Publication dispatcher

Author: jmarin

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 = {

publication/src/main/resources/application.conf

@@ -33,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"]
 
@@ -71,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
 }

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

@@ -1,7 +1,8 @@
 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 {
@@ -12,7 +13,7 @@ object AggregateAndDisclosureReports {
   }
 }
 
-class AggregateAndDisclosureReports extends Actor {
+class AggregateAndDisclosureReports extends HmdaActor {
 
   import AggregateAndDisclosureReports._