Scala Reactive Programming

MessageDispatcher

The MessageDispatcher performs the following functionality:

1. It picks up the incoming message from ActorRef (coming from non-Actor client or other Actors).
2. It enqueues that message into MailBox(MessageQueue).

3. MailBox(MessageQueue) is a thread.

Look at this from https://github.com/akka/akka/blob/v2.5.9/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala.

Look at the following code snippet from Actor's Mailbox component to understand how it deals with messages:

      private[akka] abstract class Mailbox(val messageQueue: MessageQueue)       extends ForkJoinTask[Unit] with SystemMessageQueue with Runnable {        override final def run(): Unit = {          processAllSystemMessages() //First, deal with any system messages processMailbox() //Then ...