Akka - Ist es möglich, die Nachricht im Supervisor des Schauspielers auf seinen Fehler zu bekommen?

Question

Gibt es eine Möglichkeit, eine Nachricht in der SupervisorStrategy des Supervisors zu bekommen? Ich meine den, der das Scheitern des Schauspielers verursacht hat. Ich möchte ein paar Daten davon bekommen.

Answer 1

Ein möglicher Ansatz:

1. eine Ausnahme Laufzeitausnahme definieren neue Klasse in der Lage die fehlerhafte Nachricht einzukapseln.
2. Im überwachten Akteur. Fangen Sie Exceptions und werfen Sie stattdessen die oben definierte Ausnahme mit der fehlerhaften Nachricht.
3. Erfassen Sie in der Supervisor-Strategie den neuen Ausnahmetyp und greifen Sie auf die Nachricht zu.

Zum Beispiel:

// 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 
    }