aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/kamon/actor/TraceableActor.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/kamon/actor/TraceableActor.scala')
-rw-r--r--src/main/scala/kamon/actor/TraceableActor.scala44
1 files changed, 0 insertions, 44 deletions
diff --git a/src/main/scala/kamon/actor/TraceableActor.scala b/src/main/scala/kamon/actor/TraceableActor.scala
deleted file mode 100644
index 3acbd293..00000000
--- a/src/main/scala/kamon/actor/TraceableActor.scala
+++ /dev/null
@@ -1,44 +0,0 @@
-package kamon.actor
-
-import akka.actor.{ActorRef, Actor}
-import kamon.TraceContext
-
-trait TraceableActor extends Actor with TracingImplicitConversions {
-
- final def receive = {
- case a: Any => {
- a match {
- case TraceableMessage(ctx, message) => {
- //TraceContext.current.set(ctx)
-
- tracedReceive(message)
-
- //TraceContext.current.remove()
-
- /** Publish the partial context information to the EventStream */
- context.system.eventStream.publish(ctx)
- }
- case message: Any => tracedReceive(message)
- }
- }
- }
-
- def tracedReceive: Receive
-
-}
-
-class TraceableActorRef(val target: ActorRef) {
- def !! (message: Any)(implicit sender: ActorRef) = {
- val traceableMessage = TraceableMessage(TraceContext.current.get.fork, message)
- target.tell(traceableMessage, sender)
- }
-}
-
-
-
-trait TracingImplicitConversions {
- implicit def fromActorRefToTraceableActorRef(actorRef: ActorRef) = new TraceableActorRef(actorRef)
-}
-
-case class TraceableMessage(traceContext: TraceContext, message: Any)
-