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