private val q = new ThreadLocal[MessageQueue]() {
override def initialValue = {
val queue = mailboxType.create(Some(self), Some(system))
CallingThreadDispatcherQueues(system).registerQueue(CallingThreadMailbox.this, queue)
queue
}
}
a is reference - ScalaClean replaced this with the broken code:
workspace/akka/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala:296