aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2015-07-17 15:20:15 +0200
committerIvan Topolnjak <ivantopo@gmail.com>2015-07-17 15:20:15 +0200
commit6ef32e6a02ea1545b70ce0489059684668c431d5 (patch)
tree1f148437c50168917bbe688f9c27dee1fe1500c5
parent2ce80225a5ae4d0ed7ba53be1ebe0734d4e4bca6 (diff)
downloadKamon-6ef32e6a02ea1545b70ce0489059684668c431d5.tar.gz
Kamon-6ef32e6a02ea1545b70ce0489059684668c431d5.tar.bz2
Kamon-6ef32e6a02ea1545b70ce0489059684668c431d5.zip
= akka: minor formatting fixes.
-rw-r--r--kamon-akka/src/main/scala/kamon/akka/instrumentation/DispatcherInstrumentation.scala10
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]