diff options
| author | Ivan Topolnjak <ivantopo@gmail.com> | 2018-09-28 12:08:24 +0200 |
|---|---|---|
| committer | Ivan Topolnjak <ivantopo@gmail.com> | 2018-09-28 12:08:24 +0200 |
| commit | b61c92ea3589450fd097ab79420230b61b458ae4 (patch) | |
| tree | 1db5629ec257e41e3fff0bbd50eabdc45bb05d7d /kamon-core/src/main/scala/kamon/instrumentation/HttpServer.scala | |
| parent | 6941f53c79bb4ad8adb5ebc4bcc3a3c44d02e353 (diff) | |
| download | Kamon-b61c92ea3589450fd097ab79420230b61b458ae4.tar.gz Kamon-b61c92ea3589450fd097ab79420230b61b458ae4.tar.bz2 Kamon-b61c92ea3589450fd097ab79420230b61b458ae4.zip | |
cleanup HTTP propagation, introduce a new Binary propagation
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 => |