Мой акка-стрим продолжается. Я хочу интегрировать свое приложение akka-streams с akka -cluster и DistributedPubSubMediator.
Добавить поддержку публикации довольно просто, но с частью подписки у меня проблемы.
Для справки: подписчик указан в Типичный пример:
class ChatClient(name: String) extends Actor {
val mediator = DistributedPubSub(context.system).mediator
mediator ! Subscribe("some topic", self)
def receive = {
case ChatClient.Message(from, text) =>
...process message...
}
}
Мой вопрос в том, как мне интегрировать этого актера с моим потоком и как обеспечить получение сообщений публикации при отсутствии противодавления потока?
Я пытаюсь реализовать модель pubsub, в которой один поток может публиковать сообщение, а другой поток будет использовать его (если подписан).
