diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2015-07-17 15:20:15 +0200 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2015-07-17 15:20:15 +0200 |
commit | 6ef32e6a02ea1545b70ce0489059684668c431d5 (patch) | |
tree | 1f148437c50168917bbe688f9c27dee1fe1500c5 /kamon-akka/src/main/scala | |
parent | 2ce80225a5ae4d0ed7ba53be1ebe0734d4e4bca6 (diff) | |
download | Kamon-6ef32e6a02ea1545b70ce0489059684668c431d5.tar.gz Kamon-6ef32e6a02ea1545b70ce0489059684668c431d5.tar.bz2 Kamon-6ef32e6a02ea1545b70ce0489059684668c431d5.zip |
= akka: minor formatting fixes.
Diffstat (limited to 'kamon-akka/src/main/scala')
-rw-r--r-- | kamon-akka/src/main/scala/kamon/akka/instrumentation/DispatcherInstrumentation.scala | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/kamon-akka/src/main/scala/kamon/akka/instrumentation/DispatcherInstrumentation.scala b/kamon-akka/src/main/scala/kamon/akka/instrumentation/DispatcherInstrumentation.scala index cc177aac..0b963c16 100644 --- a/kamon-akka/src/main/scala/kamon/akka/instrumentation/DispatcherInstrumentation.scala +++ b/kamon-akka/src/main/scala/kamon/akka/instrumentation/DispatcherInstrumentation.scala @@ -24,7 +24,7 @@ import akka.dispatch._ import akka.kamon.instrumentation.LookupDataAware.LookupData import kamon.Kamon import kamon.akka.{ AkkaDispatcherMetrics, ThreadPoolExecutorDispatcherMetrics, ForkJoinPoolDispatcherMetrics } -import kamon.metric.{MetricsModule, Entity} +import kamon.metric.{ MetricsModule, Entity } import org.aspectj.lang.ProceedingJoinPoint import org.aspectj.lang.annotation._ @@ -121,7 +121,6 @@ class DispatcherInstrumentation { @Pointcut("execution(* akka.dispatch.Dispatcher.LazyExecutorServiceDelegate.shutdown()) && this(lazyExecutor)") def lazyExecutorShutdown(lazyExecutor: LookupDataAware): Unit = {} - @After("lazyExecutorShutdown(lazyExecutor)") def afterLazyExecutorShutdown(lazyExecutor: LookupDataAware): Unit = { import lazyExecutor.lookupData @@ -130,17 +129,16 @@ class DispatcherInstrumentation { lazyExecutor.asInstanceOf[ExecutorServiceDelegate].executor match { case fjp: AkkaForkJoinPool ⇒ lookupData.metrics.removeEntity(Entity(lookupData.actorSystem.name + "/" + lookupData.dispatcherName, - AkkaDispatcherMetrics.Category, tags = Map("dispatcher-type" -> "fork-join-pool"))) + AkkaDispatcherMetrics.Category, tags = Map("dispatcher-type" -> "fork-join-pool"))) case tpe: ThreadPoolExecutor ⇒ lookupData.metrics.removeEntity(Entity(lookupData.actorSystem.name + "/" + lookupData.dispatcherName, - AkkaDispatcherMetrics.Category, tags = Map("dispatcher-type" -> "thread-pool-executor"))) + AkkaDispatcherMetrics.Category, tags = Map("dispatcher-type" -> "thread-pool-executor"))) case other ⇒ // nothing to remove. } } - } @Aspect @@ -169,7 +167,7 @@ trait LookupDataAware { } object LookupDataAware { - case class LookupData(dispatcherName: String, actorSystem: ActorSystem, metrics:MetricsModule = Kamon.metrics) + case class LookupData(dispatcherName: String, actorSystem: ActorSystem, metrics: MetricsModule = Kamon.metrics) private val _currentDispatcherLookupData = new ThreadLocal[LookupData] |