Akka Scala Camel. Обработка исключений

Question

У меня есть akka camel-ftp потребитель. Я хотел бы обрабатывать все исключения в коде (например, Authentification Exception или файл на ftp не может быть прочитан). Я вижу только стек из таблицы и не могу его обработать. Возможно, лучше использовать scalaz-camel.

Кроме того, я хотел бы знать, когда все файлы обрабатываются и Actor простаивает недо следующего чтение Папки FTP

class FtpWorkerActor() extends Consumer with ActorLogging { 

    override def receive: Actor.Receive = { 
    case msg: CamelMessage => /* handle files */ 

    case v: Any => /*never riched. but i need to understand if I have authentification issues etc*/ 

    } 

    override def endpointUri: String = { 
    val initDelay = 1000 // 1 second 
    val otherOptions = s"disconnect=true&throwExceptionOnConnectFailed=true&filter=#datFileFilter&delay=$processingDelay&initialDelay=$initDelay" 
    s"ftp://$username@$ftpSourcePath?username=$username&password=$pass&$otherOptions" 
    } 
} 

Answer 1

Вы должны попытаться запустить актер внутри супервизора и осуществлять обработку ошибок там. Вот больше документации о том, что: http://doc.akka.io/docs/akka/current/scala/fault-tolerance.html

В этом случае ваш руководитель будет иметь возможность перехватывать все исключения и решить, что делать с FtpWorkerActor - остановка, перезагрузка и т.д.