В случае, если вы не можете обойтись без него, довольно легко написать собственную реализацию почтового ящика, основываясь на особенностях в пакете akka.dispatch и вставляя код учета в enqueue () и dequeue (). Тогда вы могли бы либо использовать принижение (зло), либо отслеживать свои почтовые ящики в akka.actor.Extension (рекомендуется), чтобы получить доступ к статистике из вашего актера и сделать все необходимое.
ложении есть акторы Akka (Java API) (UntypeActor) и сообщения. В соответствии с контрактом API, если несколько сообщений адресованы одному и тому же субъекту, они ставятся в очередь и обрабатываются по одному.
Я хотел бы обрабатывать сообщения в актере в зависимости от размера очереди. По сути: есть ли еще одно сообщение, поставленное в очередь на момент обработки текущего сообщения в Actor.onReceive ()? Как Акка способ архивировать это?