Если актор запускается и подписывается на канал в шине событий Akka, есть ли способ для актора использовать события, которые уже были отправлены на канал, но не использованы каким-либо другим актером?
Другими словами, я хочу, чтобы актер «собирал почту». Может быть, Event Bus не подходит для этого, я не знаю.
Если на канал нет подписки, сообщения отправляются на канал DeadLetter. Теоретически вы можете написать собственный актор и подписаться на поток событий Deadletter (взгляните на актор логгера для DeadLetter), чтобы отслеживать все неиспользованные сообщения. Вы можете иметь ограниченную по размеру очередь («почтовый ящик последних n сообщений») в актере для каждого канала и заставить его слушать пользовательский канал «почта». Очередь почтового ящика также может быть основана на внешнем сохранении (redis, rdbs и т. д.). Каждый новый подписчик вашего канала должен проверять «почтовый» канал и потреблять все сообщения из очереди определенной темы в почтовом актере, если таковые имеются. Это эмулирует обычную очередь сообщений на любом брокере, поддерживающем сохраняемость.
