2017-08-16 5 views
0

メールボックスが一定のサイズまでいっぱいになったらメッセージを破棄するアクタを作成する必要があります。 閲覧アセンブリはBoundedMessageQueueはすでにオプションを提供実装があることreveiled:BoundedMessageQueueを使用してアクタを作成する

  1. メールボックス容量
  2. メールボックスプッシュタイムアウト時間は

私たちはどのように正しい構文を見つけ出すことができませんでしたBoundedMessageQueueと適切な設定でアクタを作成します。私たちが得ることができる最も近いのはProps.Create(...).WithMailbox(???)

助けが必要でした。

答えて

1

BoundedMessageQueueを基にしたBoundedMailboxを使用してください。お使いの構成では

(メールボックスがakka名前空間の外で定義する必要があることに注意してください):

akka { ... } 

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

次に、このメールボックスに俳優を作成するには:

Props.Create<ActorType>().WithMailbox("bounded-mailbox"); 
関連する問題