diff --git a/core/src/main/scala/com/github/levkhomich/akka/tracing/ActorTracing.scala b/core/src/main/scala/com/github/levkhomich/akka/tracing/ActorTracing.scala index 99c468d..9211a5a 100644 --- a/core/src/main/scala/com/github/levkhomich/akka/tracing/ActorTracing.scala +++ b/core/src/main/scala/com/github/levkhomich/akka/tracing/ActorTracing.scala @@ -49,7 +49,6 @@ trait ActorTracing extends AroundReceiveOverrideHack { self: Actor => msg match { case ts: BaseTracingSupport if receive.isDefinedAt(msg) => trace.start(ts, serviceName) - trace.record(ts, "request: " + msg.toString) case _ => } } diff --git a/core/src/test/scala/com/github/levkhomich/akka/tracing/ActorTracingSpec.scala b/core/src/test/scala/com/github/levkhomich/akka/tracing/ActorTracingSpec.scala index 908a790..87ae51e 100644 --- a/core/src/test/scala/com/github/levkhomich/akka/tracing/ActorTracingSpec.scala +++ b/core/src/test/scala/com/github/levkhomich/akka/tracing/ActorTracingSpec.scala @@ -40,7 +40,8 @@ class ActorTracingSpec extends Specification with TracingTestCommons with Tracin trace.finish(message) val span = receiveSpan() - checkAnnotation(span, "request: " + message) + span.get_annotations.size mustEqual 2 + span.get_binary_annotations mustEqual null } }