akka

0зной

3ответ

Потребитель MQTT в кластерном решении (akka, vert.x или?)

Мы начинаем проект, где нам нужно использовать некоторые сообщения от темы MQTT, но наше решение должно работать в кластере с несколькими узлами/экземплярами - должен быть масштабируемым. Проблема в т

apache-camel akka cluster-computing mqtt vert.x 2016-10-17

---

0зной

1ответ

Как протестировать аккорского актера, который порождает детей-актеров во время исполнения?

После моего other question, у меня есть UDP сервера актер следующим образом: class Listener(addr: InetSocketAddress) extends Actor { import context.system IO(Udp) ! Udp.Bind(self, addr)

scala testing akka 2016-10-18

---

2зной

1ответ

Создание потока Akka для параллельной обработки элементов коллекции

Я пытаюсь определить график потока Akka, который содержит поток параллельной обработки (я использую Akka.NET, но это не должно иметь значения). Представьте источник данных заказов, каждый заказ состои

akka akka-stream 2016-10-18

---

0зной

1ответ

Akka Streams - объединить последние операции

Я хотел бы комбинировать последние с потоками Akka, как описано here. Я не могу понять, как это сделать - пожалуйста, помогите! Thanks, Ryan.

scala akka rx-java akka-stream rx-scala 2016-10-19

---