+ core, play: introduce kamon-dispatcher

1 files changed, 26 insertions, 1 deletions

diff --git a/kamon-core/src/main/resources/reference.conf b/kamon-core/src/main/resources/reference.conf
index 12e21bd7..639d4aba 100644
--- a/kamon-core/src/main/resources/reference.conf
+++ b/kamon-core/src/main/resources/reference.conf
@@ -5,7 +5,7 @@
 kamon {
 
   # Default dispatcher for all Kamon components, unless a more specific one is configured.
-  default-dispatcher = "akka.actor.default-dispatcher"
+  default-dispatcher = "kamon.kamon-dispatcher"
 
   metrics {
 
@@ -132,4 +132,29 @@ kamon {
     # the future was created.
     ask-pattern-tracing = off
   }
+
+  kamon-dispatcher {
+    # Dispatcher is the name of the event-based dispatcher
+    type = Dispatcher
+    # What kind of ExecutionService to use
+    executor = "fork-join-executor"
+    # Configuration for the fork join pool
+    fork-join-executor {
+      # Min number of threads to cap factor-based parallelism number to
+      parallelism-min = 2
+
+      # The parallelism factor is used to determine thread pool size using the
+      # following formula: ceil(available processors * factor). Resulting size
+      # is then bounded by the parallelism-min and parallelism-max values.
+      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 = 3
+  }
 }
\ No newline at end of file