Как сделать собственный почтовый ящик как для постоянных, так и для непостоянных актеров akka? - PullRequest
Новая
       21

Как сделать собственный почтовый ящик как для постоянных, так и для непостоянных актеров akka?

0 голосов
/ 15 марта 2019

У меня есть проект с постоянными и непостоянными участниками.Моя конфигурация показана ниже.Моя реализация akka.custom.CustomMailboxType только регистрирует сообщения для непостоянных участников (акторы, которые расширяют Actor), но не регистрирует сообщения, полученные в постоянном акторе receiveCommand (те, которые расширяют PersistentActor).Он только регистрирует сохраняющиеся данные, сделанные в in inmemory-snapshot-store.Как вы можете перехватить все сообщения? 

akka.actor.default-mailbox {
  mailbox-type = "akka.custom.CustomMailboxType"
}

unbounded-mailbox {
  mailbox-type = "akka.custom.CustomMailboxType"
}

akka.loglevel = DEBUG

akka.actor.debug {
  receive = on
  lifecycle = off
}

akka.actor.mailbox.requirements {
  "akka.dispatch.UnboundedMessageQueueSemantics" = unbounded-mailbox
  "akka.custom.CustomMailbox" = unbounded-mailbox
}


akka {
  persistence {
    journal.plugin = "inmemory-journal"
    snapshot-store.plugin = "inmemory-snapshot-store"
  }
}
...