Merge pull request #1521 from akka/wip-3342-mailbox-split-∂π

rewrite mailbox selection logic, see #3342
This commit is contained in:
Roland Kuhn 2013-06-03 03:53:17 -07:00
commit 0191458a24
38 changed files with 907 additions and 448 deletions

View file

@ -203,8 +203,7 @@ object DispatcherDocSpec {
import akka.dispatch.{
Envelope,
MessageQueue,
QueueBasedMessageQueue,
UnboundedMessageQueueSemantics
UnboundedQueueBasedMessageQueue
}
// This constructor signature must exist, it will be called by Akka
@ -213,7 +212,7 @@ object DispatcherDocSpec {
// The create method is called to create the MessageQueue
final override def create(owner: Option[ActorRef],
system: Option[ActorSystem]): MessageQueue =
new QueueBasedMessageQueue with UnboundedMessageQueueSemantics {
new UnboundedQueueBasedMessageQueue {
final val queue = new ConcurrentLinkedQueue[Envelope]()
}
}

View file

@ -40,7 +40,7 @@ class RouterViaProgramDocSpec extends AkkaSpec with ImplicitSender {
val actor3 = system.actorOf(Props[ExampleActor1], "actor3")
val routees = Vector[String]("/user/actor1", "/user/actor2", "/user/actor3")
val router = system.actorOf(
Props().withRouter(RoundRobinRouter(routees = routees)))
Props.empty.withRouter(RoundRobinRouter(routees = routees)))
//#programmaticRoutingRouteePaths
1 to 6 foreach { i router ! Message1(i) }
val received = receiveN(6, 5.seconds.dilated)