저는 Akka와 액터 모델을 처음 접했고 배우를 테스트하는 동안 어려움을 겪고 있습니다.액터가 특정 메시지를 수신했는지 테스트합니다.
Akka documentation에서 로컬 포트에 자신을 경계하고 다음 코드로 들어오는 연결을 청취하는 간단한 배우를 만들 수 있습니다
class Server extends Actor {
import Tcp._
import context.system
IO(Tcp) ! Bind(self, new InetSocketAddress("localhost", 12345))
def receive = {
case b @ Bound(localAddress) =>
// do some logging or setup ...
// rest omitted for brevity
}
}
나는 Server
배우를 작성하는 테스트를 작성하고 싶습니다 액터가 IO(Tcp)
에서 Bound
메시지를 수신했는지 확인합니다. 나는 이것이 가능하다고 생각하지만 나는 뭔가를 놓치고 있다고 생각한다. expectMsg
에 대한 나의 이해는 테스트중인 액터에게 메시지를 보내는 액터에 적용되어 무언가를 수신하고받은 액티비티에 대해 주장합니다. 실제로 내가 만든 배우가받은 것을 확인할 수 있습니까?