! core,akka: use our own dispatcher instead of Akka's default dispatcher.

2 files changed, 7 insertions, 12 deletions

diff --git a/kamon-akka/src/main/resources/reference.conf b/kamon-akka/src/main/resources/reference.conf
index 0ea6b75b..1ffe7a7f 100644
--- a/kamon-akka/src/main/resources/reference.conf
+++ b/kamon-akka/src/main/resources/reference.conf
@@ -13,7 +13,7 @@ kamon {
     ask-pattern-timeout-warning = off
 
     # Default dispatcher for all akka module operations
-    dispatcher = "akka.actor.default-dispatcher"
+    dispatcher = kamon.default-dispatcher
   }
 
   metric.filters {
diff --git a/kamon-core/src/main/resources/reference.conf b/kamon-core/src/main/resources/reference.conf
index 2bc217b0..dabeda69 100644
--- a/kamon-core/src/main/resources/reference.conf
+++ b/kamon-core/src/main/resources/reference.conf
@@ -86,16 +86,14 @@ kamon {
     dispatchers {
 
       # Dispatcher for the actor that will collect all recorded metrics on every tick and dispatch them to all subscribers.
-      metric-collection = akka.actor.default-dispatcher
+      metric-collection = kamon.default-dispatcher
 
       # Dispatcher for the Kamon refresh scheduler, used by all MinMaxCounters and Gaugues to update their values.
-      refresh-scheduler = akka.actor.default-dispatcher
+      refresh-scheduler = kamon.default-dispatcher
     }
   }
 
 
-
-
   trace {
 
     # Level of detail used when recording trace information. The posible values are:
@@ -144,14 +142,16 @@ kamon {
     }
 
     # Default dispatcher for all trace module operations
-    dispatcher = "akka.actor.default-dispatcher"
+    dispatcher = kamon.default-dispatcher
   }
 
-  kamon-dispatcher {
+  default-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
@@ -165,10 +165,5 @@ kamon {
       # 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