From 84a67e00581aecb0a7d440a8730834944e4829eb Mon Sep 17 00:00:00 2001
From: John St John <johnthesaintjohn@gmail.com>
Date: Thu, 5 Oct 2017 15:39:30 -0700
Subject: cleanup logging, remove old tracing, use new tracing library

---
 ...ceptionLoggingSizedBufferingTraceConsumer.scala | 35 ----------------------
 1 file changed, 35 deletions(-)
 delete mode 100644 src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala

(limited to 'src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala')

diff --git a/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala b/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala
deleted file mode 100644
index 399e2c6..0000000
--- a/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala
+++ /dev/null
@@ -1,35 +0,0 @@
-package xyz.driver.core.trace
-
-import com.google.cloud.trace.v1.consumer.FlushableTraceConsumer
-import com.google.devtools.cloudtrace.v1.Traces
-import com.typesafe.scalalogging.Logger
-
-import scala.util.control.NonFatal
-
-/**
-  * ExceptionLoggingFlushableTraceConsumer simply wraps a flushable trace consumer and catches/logs any exceptions
-  * @param traceConsumer the flusable trace consumer to wrap
-  * @param log where to log any exceptions
-  */
-class ExceptionLoggingFlushableTraceConsumer(traceConsumer: FlushableTraceConsumer, log: Logger)
-    extends FlushableTraceConsumer {
-
-  private val flushableTraceConsumer = traceConsumer
-
-  private def exceptionLogger(exception: Throwable): Unit =
-    log.error(s"Encountered exception logging to google $exception")
-
-  override def receive(trace: Traces): Unit =
-    try {
-      flushableTraceConsumer.receive(trace)
-    } catch {
-      case NonFatal(e) => exceptionLogger(e)
-    }
-
-  override def flush(): Unit =
-    try {
-      flushableTraceConsumer.flush()
-    } catch {
-      case NonFatal(e) => exceptionLogger(e)
-    }
-}
-- 
cgit v1.2.3