diff options
Diffstat (limited to 'src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala')
-rw-r--r-- | src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala | 35 |
1 files changed, 0 insertions, 35 deletions
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) - } -} |