aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/GoogleTracer.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/GoogleTracer.scala')
-rw-r--r--src/main/scala/GoogleTracer.scala3
1 files changed, 0 insertions, 3 deletions
diff --git a/src/main/scala/GoogleTracer.scala b/src/main/scala/GoogleTracer.scala
index 5b3c9df..7ffd356 100644
--- a/src/main/scala/GoogleTracer.scala
+++ b/src/main/scala/GoogleTracer.scala
@@ -47,10 +47,8 @@ class GoogleTracer(projectId: String,
lazy val queue: SourceQueueWithComplete[Span] = {
Source
.queue[Span](bufferSize, OverflowStrategy.dropNew)
- .log("debug")
.viaMat(batchingPipeline)(Keep.left)
.mapAsync(concurrentConnections) { (traces: Traces) =>
- println(traces)
Marshal(traces).to[RequestEntity].map { entity =>
HttpRequest(
method = HttpMethods.PATCH,
@@ -72,7 +70,6 @@ class GoogleTracer(projectId: String,
.mapError {
case NonFatal(e) =>
system.log.error(s"Exception encountered while submitting trace", e)
- e.printStackTrace
e
}
.to(Sink.ignore)