Akka Kümesindeki bir Abonenin alım yöntemini nasıl test edebilirim?

Question

aşağıdaki Subscriber soyut temel sınıf var:

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") 
    } 
} 

Ve bunu bir alt sınıf abone olduğu için konulara yayınlanmaktadır mesajları aldığı test etmek istiyorum. Belirli aktörler TestProbe yoluyla olduğunu ulaşan mesajların hakkında iddialarda bulunan bilmek

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) 

tek yolu, ama ben bir TestProbe uzatmak yapabilir bilmiyorum: göstermektedir Bazı basit yalancı kod şudur sınıfım.

Genellikle, Akka docs, ilişkili test paketleriyle birlikte bir örnek kod içeriyor, ancak receive yöntemini test etmekle ilgili Akka Cluster belgelerinde hiçbir şey bulamadım.

Herhangi bir öneri var mı?

Answer 1

Bu Bağımlılık Enjeksiyonunun test edilebilirlik konusunda yardımcı olduğu bir ders kitabı örneğidir.

Abone yapıcıda DistPubSub için arabulucuyu doğrudan doğruya almak yerine alırsanız, sınama donanımınızın bir parçası olarak DistPubSub'u kullanmanıza gerek kalmadan Suscriber aktörünü yalnız olarak test edebilirsiniz.