raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Add abstract method for dispatcher name

Browse source
This commit is contained in:
Peter Vlugter 2011-07-25 13:24:39 +12:00
parent ae35e61a02
commit f406cd98e0
2 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-actor/src/main/scala/akka/dispatch/MessageHandling.scala
View file

@ -68,6 +68,11 @@ trait MessageDispatcher {
*/
private[akka] def createMailbox(actorRef: ActorRef): AnyRef
/**
* Name of this dispatcher.
*/
def name: String
/**
* Attaches the specified actorRef to this dispatcher
*/

4
akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala
View file

@ -32,7 +32,7 @@ import scala.annotation.tailrec
object CallingThreadDispatcher {
lazy val global = new CallingThreadDispatcher
lazy val global = new CallingThreadDispatcher("global-calling-thread")
// PRIVATE DATA
@ -104,7 +104,7 @@ object CallingThreadDispatcher {
* @author Roland Kuhn
* @since 1.1
*/
class CallingThreadDispatcher(val warnings: Boolean = true) extends MessageDispatcher {
class CallingThreadDispatcher(val name: String = "calling-thread", val warnings: Boolean = true) extends MessageDispatcher {
import CallingThreadDispatcher._
private[akka] override def createMailbox(actor: ActorRef) = new CallingThreadMailbox