1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
package akka.kamon.instrumentation
import akka.actor.{ Props, ActorRef, ActorSystem, Cell }
import akka.dispatch.{ Envelope, MessageDispatcher }
import akka.routing.RoutedActorCell
import org.aspectj.lang.ProceedingJoinPoint
import org.aspectj.lang.annotation._
@Aspect
class RoutedActorCellInstrumentation {
def routerInstrumentation(cell: Cell): RouterMonitor =
cell.asInstanceOf[RouterInstrumentationAware].routerInstrumentation
@Pointcut("execution(akka.routing.RoutedActorCell.new(..)) && this(cell) && args(system, ref, props, dispatcher, routeeProps, supervisor)")
def routedActorCellCreation(cell: RoutedActorCell, system: ActorSystem, ref: ActorRef, props: Props, dispatcher: MessageDispatcher, routeeProps: Props, supervisor: ActorRef): Unit = {}
@After("routedActorCellCreation(cell, system, ref, props, dispatcher, routeeProps, supervisor)")
def afterRoutedActorCellCreation(cell: RoutedActorCell, system: ActorSystem, ref: ActorRef, props: Props, dispatcher: MessageDispatcher, routeeProps: Props, supervisor: ActorRef): Unit = {
cell.asInstanceOf[RouterInstrumentationAware].setRouterInstrumentation(
RouterMonitor.createRouterInstrumentation(cell))
}
@Pointcut("execution(* akka.routing.RoutedActorCell.sendMessage(*)) && this(cell) && args(envelope)")
def sendMessageInRouterActorCell(cell: RoutedActorCell, envelope: Envelope) = {}
@Around("sendMessageInRouterActorCell(cell, envelope)")
def aroundSendMessageInRouterActorCell(pjp: ProceedingJoinPoint, cell: RoutedActorCell, envelope: Envelope): Any = {
routerInstrumentation(cell).processMessage(pjp)
}
}
trait RouterInstrumentationAware {
def routerInstrumentation: RouterMonitor
def setRouterInstrumentation(ai: RouterMonitor): Unit
}
object RouterInstrumentationAware {
def apply(): RouterInstrumentationAware = new RouterInstrumentationAware {
private var _ri: RouterMonitor = _
def setRouterInstrumentation(ai: RouterMonitor): Unit = _ri = ai
def routerInstrumentation: RouterMonitor = _ri
}
}
@Aspect
class MetricsIntoRouterCellsMixin {
@DeclareMixin("akka.routing.RoutedActorCell")
def mixinActorCellMetricsToRoutedActorCell: RouterInstrumentationAware = RouterInstrumentationAware()
}
|
