Вопросы по теме 'distributedpubsub'

Как я могу протестировать метод получения подписчика в кластере Akka?
У меня есть следующий абстрактный базовый класс Subscriber : abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging { import DistributedPubSubMediator.{ Subscribe, SubscribeAck } val mediator =...
302 просмотров