= core,system.metrics: fixed serialization errors when using akka.actor.serialize-messages = on

1 files changed, 26 insertions, 22 deletions

diff --git a/kamon-system-metrics/src/main/scala/kamon/metrics/MemoryMetrics.scala b/kamon-system-metrics/src/main/scala/kamon/metrics/MemoryMetrics.scala
index 6f3eb6df..14051427 100644
--- a/kamon-system-metrics/src/main/scala/kamon/metrics/MemoryMetrics.scala
+++ b/kamon-system-metrics/src/main/scala/kamon/metrics/MemoryMetrics.scala
@@ -62,27 +62,31 @@ object MemoryMetrics extends MetricGroupCategory {
       SwapFree -> swapFree)
   }
 
-  val Factory = new MetricGroupFactory {
-
-    type GroupRecorder = MemoryMetricRecorder
-
-    def create(config: Config, system: ActorSystem): GroupRecorder = {
-      val settings = config.getConfig("precision.system.memory")
-
-      val usedConfig = settings.getConfig("used")
-      val freeConfig = settings.getConfig("free")
-      val bufferConfig = settings.getConfig("buffer")
-      val cacheConfig = settings.getConfig("cache")
-      val swapUsedConfig = settings.getConfig("swap-used")
-      val swapFreeConfig = settings.getConfig("swap-free")
-
-      new MemoryMetricRecorder(
-        Histogram.fromConfig(usedConfig, Scale.Mega),
-        Histogram.fromConfig(freeConfig, Scale.Mega),
-        Histogram.fromConfig(swapUsedConfig, Scale.Mega),
-        Histogram.fromConfig(swapFreeConfig, Scale.Mega),
-        Histogram.fromConfig(bufferConfig, Scale.Mega),
-        Histogram.fromConfig(cacheConfig, Scale.Mega))
-    }
+  val Factory = MemoryMetricGroupFactory
+}
+
+case object MemoryMetricGroupFactory extends MetricGroupFactory {
+
+  import MemoryMetrics._
+
+  type GroupRecorder = MemoryMetricRecorder
+
+  def create(config: Config, system: ActorSystem): GroupRecorder = {
+    val settings = config.getConfig("precision.system.memory")
+
+    val usedConfig = settings.getConfig("used")
+    val freeConfig = settings.getConfig("free")
+    val bufferConfig = settings.getConfig("buffer")
+    val cacheConfig = settings.getConfig("cache")
+    val swapUsedConfig = settings.getConfig("swap-used")
+    val swapFreeConfig = settings.getConfig("swap-free")
+
+    new MemoryMetricRecorder(
+      Histogram.fromConfig(usedConfig, Scale.Mega),
+      Histogram.fromConfig(freeConfig, Scale.Mega),
+      Histogram.fromConfig(swapUsedConfig, Scale.Mega),
+      Histogram.fromConfig(swapFreeConfig, Scale.Mega),
+      Histogram.fromConfig(bufferConfig, Scale.Mega),
+      Histogram.fromConfig(cacheConfig, Scale.Mega))
   }
 }
\ No newline at end of file