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 
    }