Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- trait Log extends Sender {
- abstract override def send(event: ServingError): Unit = {
- Logger.log(event.description)
- super.send(event)
- }
- }
- trait Metric extends Sender {
- abstract override def send(event: ServingError): Unit = {
- Monitor.incrementCounter(event.getClass.getSimpleName, "errorCode" -> event.code.toString)
- super.send(event)
- }
- }
- trait S3_Backup extends Sender {
- abstract override def send(event: ServingError): Unit = {
- S3_Client.upload(event.content)
- super.send(event)
- }
- }
- trait Kafka extends Sender {
- abstract override def send(event: ServingError): Unit = {
- Try(KafkaProducer.send(event.content)).getOrElse(super.send(event))
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement