Aktar aktör sınırlı posta kutusu MessageQueueAppendFailedException

Question

OOM'dan kaçınmak için, bazı Akka 1.1.3 aktörlerimin posta kutusu boyutunu paylaşılan bir özel dağıtım görevlisi ile sınırlandırıyorum. Örneğin: (: actor.stop(), bekle gibi ne yazık ki görünüyor ve actor.start() bir ActorStartException atacağım yan notu) İsterdim

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

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

yüzden mesajı memba üreticilerin duraklatma yapabilirsiniz taşan posta kutusuna tepki. Kuyruk doldurma ve kuyruk boşaltma kuyruğu arasında bazı veri kaybı kabul edilebilir.

Dispatchers tarihinde Akka en bölüm mesajı içinde posta kutusuna ilave edilemezse (“BlockingMessageTransferQueue transferi zaman aşımına uğradı”)

bir MessageQueueAppendFailedException atacağım Actor bir mesaj göndermeye çalışırken diyor pushTimeout tarafından belirtilen süre.

Bu özel durumu nereden alabilirim?

Dokümantasyon, her myActor ! message'u bir deneme/yakalamaya sarmam gerektiği gibi ses çıkarır. Bu doğru mu? Onun kullanımını merkezileştirmeyi çok isterim. Supervisor'um belki de onu engelleyebilir ve işleyicimi çalıştırabilir mi?

Answer 1

cc.spray.json._ kullanmayı deneyin, çünkü akka'nın veya twitter'ın çöplüğünün üzerine yerleştirilmiştir.