aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/akka/PoolMonitorInstrumentation.scala
diff options
context:
space:
mode:
authorDiego Parra <dparra@despegar.com>2013-06-03 10:15:32 -0300
committerDiego Parra <dparra@despegar.com>2013-06-03 10:15:32 -0300
commitcad83e95166d91225e126aa6a0fab493b3baca59 (patch)
tree5bdaeff4559aeba7defd888cf4c97bea31c829ef /src/main/scala/akka/PoolMonitorInstrumentation.scala
parent8f4c649e6082671c416b250589540005d9fe1bf8 (diff)
downloadKamon-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.scala16
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 = {
+
+ }
+}