Akka/scala-OversizedPayloadException Как это сделать?

Question

У нас есть распределенное приложение на кластере akka. Актер «А» отправляет сообщение большого размера удаленному актеру. И мы получаем следующее предупреждение:

2016-08-10 23: 08: 29,737 [EndpointWriter] ERROR - Transient ассоциации ошибки (ассоциация остается живой) akka.remote.OversizedPayloadException: Отбрасывая негабаритный полезный груз отправлен Actor [akka.tcp: //abcd@127.0.0.1: 51665/temp/$ b]: max allowed размер 128000 байт, действительный размер кодированного класса common.data.model.configuration.UserList был 571444 байт.

Мы знаем, что мы можем увеличить значение в configuration. Но мы хотели проверить, превышает ли размер предел по умолчанию, который мы хотим отправить другому сообщению. Пробовал поиск, но не повезло, что большинство из них только рассказывают о том, как настроить его, никто не говорит о том, как его обрабатывать, и отправить сообщение удаленной машине. Любое предложение или помощь будут оценены.

Answer 1

На самом деле, мы можем справиться с этим, нужно просто подписаться на akka.event.Logging.Error, и проверить, если причина OversizedPayloadException:

import akka.actor.{Actor, Props} 

class Listener extends Actor { 
    override def receive: Receive = { 
    case akka.event.Logging.Error(cause, _, _, _) 
     // this internal Akka class is package-private, hence we have to check it's classname :(
     if cause.getClass.getName == "akka.remote.OversizedPayloadException" => 
     // handle it here! 
    } 
} 

val listener = system.actorOf(Props(new Listener)) 
system.eventStream.subscribe(listener, classOf[akka.event.Logging.Error]) 

Answer 2

Постарайтесь подписаться на поток событий. Будем надеяться, что исключение заканчивается:

import akka.actor.{Actor, Props} 
import akka.remote.OversizedPayloadException 

class Listener extends Actor { 
    def receive = { 
    case d: OversizedPayloadException => { 
     // DO SOMETHING 
    } 
    } 
} 
val listener = system.actorOf(Props(classOf[Listener], this)) 
system.eventStream.subscribe(listener, classOf[OversizedPayloadException]) 

Подробнее here

Answer 3

Добавлено тот же запрос для рассылки группы Акко. Они сказали, что нет возможности передать это «OversizedPayloadException». Предлагаем вам проверить размер данных и перенести его, прежде чем мы вернемся к актеру.