我有一位演員，其唯一的責任是將從外部接口（命令行，用戶等）收到的消息轉發到適當的主題。我想測試它是否正確發佈這些消息。 我將需要創建一些虛擬用戶，他們會期望發佈到某個主題的消息並對其收到的消息作出斷言。 這裏是我的代碼，我試圖認識到： Messages.scala case class Foo(foo: String)
InterfaceForwardingActor.scala import
我有以下Subscriber抽象基類： abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging {
import DistributedPubSubMediator.{ Subscribe, SubscribeAck }
val mediator = DistributedP