From 52750a3eaf077fd332324fa10e2735230fd38116 Mon Sep 17 00:00:00 2001 From: Ivan Topolnak Date: Wed, 15 May 2013 18:50:21 -0300 Subject: wip --- src/main/scala/kamon/actor/EnhancedActor.scala | 45 -------------------------- 1 file changed, 45 deletions(-) delete mode 100644 src/main/scala/kamon/actor/EnhancedActor.scala (limited to 'src') diff --git a/src/main/scala/kamon/actor/EnhancedActor.scala b/src/main/scala/kamon/actor/EnhancedActor.scala deleted file mode 100644 index ad879505..00000000 --- a/src/main/scala/kamon/actor/EnhancedActor.scala +++ /dev/null @@ -1,45 +0,0 @@ -package kamon.actor - -import akka.actor.{ActorRef, Actor} - -trait EnhancedActor extends Actor { - protected[this] var transactionContext: TransactionContext = _ - - final def receive = { - case a: Any => { - a match { - case ContextAwareMessage(ctx, message) => { - transactionContext = ctx - println(s"Actor ${self.path.toString}. Current context: ${transactionContext}") - wrappedReceive(message) - } - case message: Any => wrappedReceive(message) - } - } - } - - - - - def wrappedReceive: Receive - - - def superTell(target: ActorRef, message: Any) = { - target.tell(ContextAwareMessage(transactionContext, message), self) - } - -} - - -case class ContextAwareMessage(context: TransactionContext, message: Any) - - -case class TransactionContext(id: Long, entries: List[ContextEntry]) { - def append(entry: ContextEntry) = this.copy(entries = entry :: this.entries) -} -sealed trait ContextEntry - -case class DeveloperComment(comment: String) extends ContextEntry - -case class MessageExecutionTime(actorPath: String, begin: Long, end: Long) extends ContextEntry - -- cgit v1.2.3