akka

1зной

1ответ

Как запрашивать базу данных каждые X минут

Я хочу контролировать процесс заказа через akka и scala и хочу создать актерскую систему. сообщения, которые поступают из интернет-магазина, хранятся в mongoDB и хранятся в 4 разных коллекциях. Каждой

0зной

2ответ

Вызывает ли актерский призыв аккера?

У меня есть следующий код, который я должен работать около 100 раз: val system = ActorSystem("mySystem") val myActorObject = system.actorOf(Props[MyActorClass], name = "myactor") implicit va

0зной

1ответ

Akka Port Forwarding

Я пытаюсь выполнить перенаправление портов в направлении моей программы Akka, где клиент может общаться с сервером через Интернет. Я настроил свой маршрутизатор, и механизм переадресации портов работа

2зной

2ответ

Akka Streams - Разделить данные о входящих источниках на основе некоторого предиката

Я новичок в инфраструктуре Akka Streams, и я хочу знать возможности решения моей проблемы с целью потоков Akka. Представьте себе, что проблема: Несколько крупных источников итераций, например. 3-4 бол

0зной

1ответ

Получить базовый актер от ActorRef с помощью набора тестов Akka

Есть ли способ получить базовый актер из ActorRef с помощью набора тестов Actka Actor? Я знаю TestActorRef, но я не могу использовать их в своих тестах, так как актеры создаются в моем приложении. Все

1зной

2ответ

Java CompletableFuture: Избегайте обратного вызова ад

У меня есть вопрос относительно CompletableFuture в Java. Я жду завершения CompletableFuture и в зависимости от полученного результата, я хочу либо вызвать новую задачу, либо дождаться завершения Comp

4зной

2ответ

Scala + SBT - Как настроить reference.conf для затененной Akka библиотеки

TL; DR Я пытаюсь оттенок версии akka библиотеки и связать его с моим приложением (чтобы быть в состоянии запустить spray-can сервер на CDH 5.7 версии Spark 1.6). Процесс затенения messes up akka's def

0зной

1ответ

`akka.pattern.after` - Понимание аргумента` duration`?

Использование Scala 2.11.8, учитывая, что Future спит 5 секунд, прежде чем вернуться (), я назвал akka.pattern.ask с тайм-аут 1 второй: import scala.concurrent.duration._ import scala.concurrent._ i