diff options
author | Diego Parra <dparra@despegar.com> | 2013-06-03 10:15:32 -0300 |
---|---|---|
committer | Diego Parra <dparra@despegar.com> | 2013-06-03 10:15:32 -0300 |
commit | cad83e95166d91225e126aa6a0fab493b3baca59 (patch) | |
tree | 5bdaeff4559aeba7defd888cf4c97bea31c829ef /src/main/scala/akka/PoolMonitorInstrumentation.scala | |
parent | 8f4c649e6082671c416b250589540005d9fe1bf8 (diff) | |
download | Kamon-cad83e95166d91225e126aa6a0fab493b3baca59.tar.gz Kamon-cad83e95166d91225e126aa6a0fab493b3baca59.tar.bz2 Kamon-cad83e95166d91225e126aa6a0fab493b3baca59.zip |
WIP:Metrics 3
Diffstat (limited to 'src/main/scala/akka/PoolMonitorInstrumentation.scala')
-rw-r--r-- | src/main/scala/akka/PoolMonitorInstrumentation.scala | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/src/main/scala/akka/PoolMonitorInstrumentation.scala b/src/main/scala/akka/PoolMonitorInstrumentation.scala new file mode 100644 index 00000000..167083e8 --- /dev/null +++ b/src/main/scala/akka/PoolMonitorInstrumentation.scala @@ -0,0 +1,16 @@ +package akka + +import org.aspectj.lang.annotation._ + +@Aspect("perthis(poolMonitor(*))") +class PoolMonitorAspect { + println("Created PoolMonitorAspect") + + @Pointcut("execution(scala.concurrent.forkjoin.ForkJoinPool.new(..)) && this(pool)") + protected def poolMonitor(pool:scala.concurrent.forkjoin.ForkJoinPool):Unit = {} + + @After("poolMonitor(pool)") + def beforePoolInstantiation(pool: scala.concurrent.forkjoin.ForkJoinPool):Unit = { + + } +} |