aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/akka/PoolMonitorInstrumentation.scala
diff options
context:
space:
mode:
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 = {
+
+ }
+}