Akka-2インスタンスは、メールボックスをオーバーフローさせずにn TimeUnitsごとにメッセージを送信します。

Question

Akka-2インスタンスは無限ループのままで、処理するデータがないか10分ごとにチェックする必要があります。

ループを設計して、インスタンスが自分自身を呼び出し、何らかの作業をしてから一定時間スリープするようにするにはどうすればよいですか？

また、メールボックスサイズをもうクエリできないことがわかりました。作業タスク（この場合はディスパッチ機能）がアクティブである限り、どのようにメッセージが無視されることを確認しますか？

case class Dispatch() 

// Automatical start? The start function has been removed since Akka 2 ? 
val dispatcher = system.actorOf(Props[MailDispatcher]) 

class MailDispatcher extends Actor { 

    private val interval = Config.getLong("mail.check.interval") 
    context.setReceiveTimeout(Duration(interval, TimeUnit.SECONDS)) 

    def receive = { 
    case ReceiveTimeout => { 
     self ! Dispatch   
    } 
    case Dispatch => dispatch() 
    case e: Exception => Logger.error("unexpected Error: " + e) 
    } 

    def dispatch() {  
     // trigger mail-dispatch  
    } 
} 

Answer 1

私は次のことをお勧めしたい：

使用：あなたはReceiveTimeoutというメッセージを取得するときhttp://akka.io/docs/akka/2.0-RC2/scala/actors.html#initial-receive-timeout

その後、あなたは仕事のためにポーリングし、そして自分自身のメールボックスに作品を送っています。