Custom dispatcher for api execution context

Author: jmarin

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
+}
+
 

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)