I am using Scala 2.9.2 and Akka 2.0.x. I have two actors:
class DoWorkActor extends Actor {
val manager = context.system.ActorSelection("user/manager")
def receive = {
case "go" => {
// do some work
manager ! "success"
}
}
}
class ManagerActor extends Actor {
var successCount = 0
def receive = {
case "success" => {
successCount += 1
}
case "getSuccessCount" => {
sender ! successCount
}
}
}
I want to verify that the DoWorkActor sends a "success" to the
ManagerActor. I'm trying with the following test:
class DoWorkActorSpec extends FunSpec {
val config = ConfigFactory.load()
implicit val actorSystem = ActorSystem("test", config)
implicit val timeout = Timeout(500)
val managerRef = TestActorRef(new ManagerActor)
actorSystem.actorOf(Props(managerRef.underlyingActor), name = "manager")
describe("#receive") {
it("should send a success message to the manager") {
val doWorkActor = TestActorRef(new DoWorkActor)
doWorkActor ! "go"
val count = Await.result((managerRef ? "getSuccessCount"),
5 seconds)
assert(count === 1)
}
}
Somtimes this test passes, but usually it fails. I put "println" statements
in the Manger actor and I can see that it usually gets the
"getSuccessCount" message before the "success" message. If I put in a
"Thread.sleep(100)" after sending the "go" message to the DoWorkActor, the
test passes.
I thought by using TestActorRef's, things would be asynchronous but it
seems like they're not. Am I doing something wrong? Any suggestions?
Thanks.
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
