Akka - 是否有可能在演员的主管中收到失败的消息？

Question

有没有办法在演员主管的SupervisorStrategy中获取消息？我的意思是导致演员失败的那个人。我想从中获取一些数据。

Answer 1

一种可能的方法：

1. 定义一个新的运行时异常的异常类能够封装故障消息。
2. 在受监督的演员。捕捉异常并用错误的消息抛出上面定义的异常。
3. 在主管策略中，捕获新的异常类型并访问消息。

例如：

// The new exception type 
case class MessageException( 
    akkaMessage: Any, 
    originalException: Throwable 
) extends RuntimeException("Exception due to message") 

// In the supervised actor 
def receive = { 
    case msg => try{ process(msg) } catch { 
    case t => throw MessageException(msg,t) 
    } 
} 

// In the supervisor 
override val supervisorStrategy = 
    OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange = 1 minute) { 
    case MessageException(msg,t) => //decide what to do 
    }