как получить размер очереди сообщений от актера akka? - PullRequest
18 голосов
/ 17 марта 2011

В приложении есть акторы Akka (Java API) (UntypeActor) и сообщения. В соответствии с контрактом API в случае, если несколько сообщений адресованы одному и тому же субъекту, они ставятся в очередь и обрабатываются по одному.

Я бы хотел обрабатывать сообщения в актере в зависимости от размера очереди. По сути: есть ли еще одно сообщение, поставленное в очередь на момент обработки текущего сообщения в Actor.onReceive ()? Как Акка способ архивировать это?

1 Ответ

13 голосов
/ 18 марта 2011

В UntypedActor вы делаете:

getContext (). GetMailboxSize ();

...