src/main/scala/akka/PoolMonitorInstrumentation.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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 = {

  }
}