scala – 如何在Akka Cluster中测试订阅者的接收方法？

abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging {
  import DistributedPubSubMediator.{ Subscribe,SubscribeAck }

  val mediator = DistributedPubSub(context.system).mediator

  // subscribe to each topic
  topics.foreach{mediator ! Subscribe(_,self)}

  def receive = {
    case SubscribeAck(Subscribe(name,None,`self`)) ?
      log.info(s"Subscribing to $name")
  }
}

我想测试它是否接收发布到子类订阅的主题的消息.一些简单的伪代码表明如下：

val topic = "foo"

class FooSubscriber extends Subscriber(Seq(topic))

val fooSubActor = system.actorOf(Props[FooSubscriber])    
val mediator = DistributedPubSub(system).mediator
val msg = "This is a string"

// Publish the msg to the "foo" topic.
mediator ! Publish(topic,msg)

fooSubActor.expectMsg(msg)

我知道对特定actor收到的消息进行断言的唯一方法是使用TestProbe,但我不知道如何让TestProbe扩展我的类.

通常,Akka docs有大量的示例代码和相关的测试套件,但我在Akka Cluster文档中找不到与测试接收方法相关的任何内容.

有没有人有建议？