DeadLetterWatcher

DeadLetterWatcher.scala

import akka.actor._
import com.typesafe.scalalogging.slf4j.StrictLogging

/** DeadLetterを監視するactor
 */
object DeadLetterWatcher {
  val actorName = "dead_letter_watcher"
  def props(): Props = Props(new DeadLetterWatcher)
  def apply(context: ActorRefFactory): ActorRef = context.actorOf(props(), actorName)
}

class DeadLetterWatcher extends Actor with StrictLogging {
  override def preStart(): Unit = {
    super.preStart()
    context.system.eventStream.subscribe(self, classOf[DeadLetter])
  }

  override def postStop(): Unit = {
    context.system.eventStream.unsubscribe(self, classOf[DeadLetter])
    super.postStop()
  }

  override def receive: Receive = {
    case DeadLetter(msg, from, to) =>
      println(s"new dead letter: $msg $from $to")
  }
}