diff options
Diffstat (limited to 'kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala b/kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala index 3cb45619..02e92f25 100644 --- a/kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala +++ b/kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala @@ -5,7 +5,6 @@ import java.time.Duration import com.typesafe.config.Config import kamon.context.Context -import kamon.context.HttpPropagation.Direction import kamon.instrumentation.HttpServer.Settings.TagMode import kamon.metric.MeasurementUnit.{time, information} import kamon.trace.{IdentityProvider, Span} @@ -259,7 +258,7 @@ object HttpServer { override def receive(request: HttpRequest): RequestHandler = { val incomingContext = if(settings.enableContextPropagation) - _propagation.readContext(request) + _propagation.read(request) else Context.Empty val requestSpan = if(settings.enableTracing) @@ -296,7 +295,7 @@ object HttpServer { } if(settings.enableContextPropagation) { - _propagation.writeContext(context, response, Direction.Returning) + _propagation.write(context, response) } _metrics.foreach { httpServerMetrics => |