diff options
author | Boris Giftge <bgiftge@kixeye.com> | 2014-10-22 18:19:15 -0700 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2014-10-23 18:53:21 +0200 |
commit | 2bc964779fd260af550e7b40fbb2991d997ed000 (patch) | |
tree | 8c1b529c130f6f4cfeb0c490e41baffa1ba1c117 /kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala | |
parent | 52233d1ddef10b3c40df134b33f0d255dce85ae5 (diff) | |
download | Kamon-2bc964779fd260af550e7b40fbb2991d997ed000.tar.gz Kamon-2bc964779fd260af550e7b40fbb2991d997ed000.tar.bz2 Kamon-2bc964779fd260af550e7b40fbb2991d997ed000.zip |
= core,system.metrics: fixed serialization errors when using akka.actor.serialize-messages = on
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala | 30 |
1 files changed, 17 insertions, 13 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala b/kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala index bb412f79..d2cb4e38 100644 --- a/kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala +++ b/kamon-core/src/main/scala/kamon/metric/ActorMetrics.scala @@ -69,21 +69,25 @@ object ActorMetrics extends MetricGroupCategory { (Errors -> errors)) } - val Factory = new MetricGroupFactory { - type GroupRecorder = ActorMetricsRecorder + val Factory = ActorMetricGroupFactory +} - def create(config: Config, system: ActorSystem): ActorMetricsRecorder = { - val settings = config.getConfig("precision.actor") +case object ActorMetricGroupFactory extends MetricGroupFactory { + import ActorMetrics._ - val processingTimeConfig = settings.getConfig("processing-time") - val timeInMailboxConfig = settings.getConfig("time-in-mailbox") - val mailboxSizeConfig = settings.getConfig("mailbox-size") + type GroupRecorder = ActorMetricsRecorder - new ActorMetricsRecorder( - Histogram.fromConfig(processingTimeConfig), - Histogram.fromConfig(timeInMailboxConfig), - MinMaxCounter.fromConfig(mailboxSizeConfig, system), - Counter()) - } + def create(config: Config, system: ActorSystem): ActorMetricsRecorder = { + val settings = config.getConfig("precision.actor") + + val processingTimeConfig = settings.getConfig("processing-time") + val timeInMailboxConfig = settings.getConfig("time-in-mailbox") + val mailboxSizeConfig = settings.getConfig("mailbox-size") + + new ActorMetricsRecorder( + Histogram.fromConfig(processingTimeConfig), + Histogram.fromConfig(timeInMailboxConfig), + MinMaxCounter.fromConfig(mailboxSizeConfig, system), + Counter()) } } |