应用中有Akka(Java API)actor(UntypeActor)和消息。 根据 API 契约(Contract),如果几条消息发送给同一个参与者,它们将被一个接一个地排队和处理。
我想根据队列大小处理 actor 中的消息。基本上:当前一条消息在 Actor.onReceive() 中处理时是否至少还有一条消息在排队? Akka 归档这个的方法是什么?
最佳答案
在你做的 UntypedActor 中:
getContext().getMailboxSize();
关于java - 如何从akka actor获取消息队列的大小?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5343731/