使用BoundedMessageQueue創建一個演員

Question

我們需要創建一個Actor，在郵箱填滿特定大小後放棄郵件。 瀏覽組件reveiled有一個BoundedMessageQueue已經實施，提供的選項：

1. 郵箱容量
2. 郵箱推超時時間

我們無法弄清楚正確的語法如何創建一個BoundedMessageQueue和適當的設置的演員。我們可以得到最接近的是Props.Create(...).WithMailbox(???)

任何幫助將appriciated。

Answer 1

使用BoundedMailbox，後者是BoundedMessageQueue。

在您的配置（請注意，郵箱需要在akka命名空間之外定義）：

akka { ... } 

bounded-mailbox { 
    mailbox-capacity = 1000 
    mailbox-push-timeout-time = 10s 
    mailbox-type = "Akka.Dispatch.BoundedMailbox, Akka" 
} 

然後，與此郵箱創建一個演員：

Props.Create<ActorType>().WithMailbox("bounded-mailbox");