aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/akka/instrumentation
diff options
context:
space:
mode:
authorDiego <diegolparra@gmail.com>2014-03-15 11:21:44 -0300
committerDiego <diegolparra@gmail.com>2014-03-15 11:25:02 -0300
commitcc079f18a2c00678397fae0714eb524dfe8961f2 (patch)
tree24dd0dcc0c63b6aa4aa01b19c7dee524f25de0d4 /kamon-core/src/main/scala/akka/instrumentation
parent75a0a4303c313266d34efd5711fe62ed70ce79b3 (diff)
downloadKamon-cc079f18a2c00678397fae0714eb524dfe8961f2.tar.gz
Kamon-cc079f18a2c00678397fae0714eb524dfe8961f2.tar.bz2
Kamon-cc079f18a2c00678397fae0714eb524dfe8961f2.zip
implementation of IMessageHandler interface in order to control Aspectj weaving messages through kamon
Diffstat (limited to 'kamon-core/src/main/scala/akka/instrumentation')
-rw-r--r--kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala3
1 files changed, 1 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala b/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala
index 3ed2e63e..c79f980c 100644
--- a/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala
+++ b/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala
@@ -22,7 +22,6 @@ import akka.dispatch.{ Envelope, MessageDispatcher }
import kamon.trace._
import kamon.metrics.{ ActorMetrics, Metrics }
import kamon.Kamon
-import kamon.trace.TraceContext
import kamon.metrics.ActorMetrics.ActorMetricRecorder
@Aspect("perthis(actorCellCreation(*, *, *, *, *))")
@@ -45,7 +44,7 @@ class BehaviourInvokeTracing {
def invokingActorBehaviourAtActorCell(cell: ActorCell, envelope: Envelope) = {}
@Around("invokingActorBehaviourAtActorCell(cell, envelope)")
- def aroundBehaviourInvoke(pjp: ProceedingJoinPoint, cell: ActorCell, envelope: Envelope): Unit = {
+ def aroundBehaviourInvoke(pjp: ProceedingJoinPoint, cell: ActorCell, envelope: Envelope): Any = {
val timestampBeforeProcessing = System.nanoTime()
val contextAndTimestamp = envelope.asInstanceOf[TraceContextAware]