aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala5
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 =>