1
ここで何かを誤解する必要があります。Akka無制限メールボックスがバインドされているようです
akka.actor.default-mailbox {
mailbox-type = "akka.dispatch.UnboundedMailbox"
}
しかし、次のように私は50件のメッセージをオフに解雇する場合:ドキュメントは、既定のメールボックスが無制限であることを想定しているが、ちょうど私が明示的な設定を追加したことを確認すると言う
1 to 50 foreach { _ =>
myActorRef ! "myMessage"
}
私は約15を得ますエラー:
ActorRefSourceActor - Dropping the new element because buffer is full and overflowStrategy is: [DropNew]
ここでは何が起こっていますか?
EDIT:
@cmbaxter - おかげであなたが正しい、私は上のビットすぎて、実際に壊れた部分を実現ませんコードを簡素化。情報の欠けている部分があった。遊びのドキュメントhereで説明したように
myActorRef
実際のWebSocket俳優のセットアップを参照。あなたが言及したように、ActorFlowを使用します。myActorRef
へのメッセージは問題ではありませんが、実際に問題が発生しているWebSocketに書き込みます。
を。あなたはAkka Streamsを使用していて、あなたの俳優を「Source」として扱っているようです。ストリームコンポーネントは、無制限のバッファリングを持つことができず、ここで見ているように下流が圧力を逆戻りし始めるときに戦略を必要とします。これはメールボックスの境界とは関係ありません – cmbaxter