핸들 Akka 액터 바운드 사서함 MessageQueueAppendFailedException

Question

OOM을 피하기 위해 일부 Akka 1.1.3 액터의 사서함 크기를 공유 사용자 지정 디스패처로 제한합니다. 예를 들어 : (: actor.stop()가, 잠깐 것처럼 슬프게 보이고, actor.start()는 ActorStartException가 발생합니다 보조 노트를) 내가 좋아하는 것

object Static { 
    val dispatcher = Dispatchers.newExecutorBasedEventDrivenWorkStealingDispatcher(
     "customDispatcher", 
     1000, 
     BoundedMailbox(capacity = 10) 
    ) 
} 

class MyActor extends Actor { 
    self.dispatcher = Static.dispatcher 
    ... 
} 

그래서 나는 메시지 상류 생산자 일시 중지 할 수 있습니다 넘쳐 사서함에 반응합니다. 대기열 채우기와 대기열 배출 사이에는 약간의 데이터 손실이 허용됩니다.

는

Dispatchers에 Akka의 장 메시지를 내 사서함 에 추가 할 수없는 경우 ("BlockingMessageTransferQueue이 전송 시간 초과")

그것이 MessageQueueAppendFailedException을 던질 것이다 액터에 메시지를 보내려고 할 때 말한다 pushTimeout에 의해 지정된 시간.

어디에서이 예외를 잡을 수 있습니까?

모든 myActor ! message을 try/catch로 랩핑해야하는 것처럼 문서화하면 소리가납니다. 그게 맞습니까? 나는 정말로 그 취급을 중앙 집중시키고 싶다. 내 Supervisor 아마 그것을 가로 채고 내 처리기를 실행할 수 있습니까?

Answer 1

akka 또는 twitter 's finagle 위에 만들어 졌기 때문에 cc.spray.json._을 사용해보십시오.