我有以下场景:
- Akka远程系统A
- Akka远程系统B
B是一个分析引擎，它向a发送一堆"fire and forget"消息。
但是如果B在分析system.shutdown之后调用，并不是所有的消息都传递给a。B的参与者系统缓冲消息吗?
我如何确保B的所有邮件现在都在A的收件箱中?我可以确定，当它是安全的B断开?我如何正确地断开B和A?
谢谢你的建议!
您可以创建几个发送消息的子actor，并在它们发送完消息后立即自杀。在监督下，你可以等待所有的子角色被终止，然后关闭系统。在我看来，这应该足够发送消息了。