Описание тега distributedpubsub
1
ответ
Как я могу проверить метод получения подписчика в кластере Akka?
У меня есть следующее Subscriber абстрактный базовый класс: abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging { import DistributedPubSubMediator.{ Subscribe, SubscribeAck } val mediator = DistributedPubSub(context.system…
01 янв '17 в 14:41
1
ответ
Как проверить издателя на DistributedPubSub в кластере Akka?
У меня есть актер, единственная ответственность которого заключается в пересылке сообщений, которые он получает от внешних интерфейсов (командной строки, пользователя и т. Д.), В соответствующие темы. Я хочу проверить, правильно ли он публикует эти …
27 дек '16 в 15:12
0
ответов
Является ли протокол IPFS PUB/SUB децентрализованным?
Мне нужно понять, как именно работает протокол pub/sub в IPFS, поскольку говорят, что файловая система децентрализована и что я понимаю, но когда я говорю о протоколе pub/sub tcp, я не вижу, как это децентрализовано. Что мне не хватает? Знаете ли вы…
07 июн '19 в 17:07
0
ответов
Неразрешенный импорт pubsub
Я работаю с Python, JS и React, и я слежу за курсом "Создание блокчейна и криптовалюты" На полпути к курсу не удалось решить эту проблему при настройке обмена сообщениями в реальном времени через PubSub (если вы разработчик блокчейна Python, вы, воз…
22 май '20 в 12:15
0
ответов
Упорядочивание событий в нескольких концентраторах событий Azure
Мне нужно отправлять события Azure IoT Hub на основе типа сообщения, то есть сообщений телеметрии, состояния и работоспособности. Теперь я хочу отправить их в 3 концентратора событий, то есть сообщение телеметрии, чтобы перейти к первому концентрато…
21 апр '20 в 19:40
0
ответов
Первое сообщение не доходит до подписанного актера
У нас есть платформа обмена сообщениями, построенная на основе Akka (2.5) с использованием кластера akka и распределенного Pubsub. В настоящее время у нас есть кластер из 25 серверов. Сценарий следующий. Actor1, созданный на Server1, подписывается н…
20 мар '21 в 14:58
0
ответов
Каков максимальный предел памяти для сообщения, которое может быть отправлено через Redis pub sub
Я использую Redis Pub Sub в своем приложении, чтобы уведомлять все модули в кластере Kubernetes, когда происходит определенная запись. Во время тестирования мне удалось отправить сообщение размером не более 22 МБ, и подписчик обработал сообщение. Но…
01 ноя '21 в 20:14
1
ответ
Администратор не выполняет дедупликацию при наличии нескольких «подписчиков» на одном узле в распределенной теме pubsub в akka typed
Изучая подписку на распределенную публикацию в новом API akka.actor.typed, мы видим, что подписка на распределенную публикацию достигается путем представления каждой подтемы публикации с помощью актера akka.actor.typed.pubsub.Topic . Чтобы смоделиро…
22 мар '22 в 05:11