akka

2зной

1ответ

Акка FSM Актер со скрежетом и неустойчивостью

Я хотел был бы сделать stashing/unpashing с FSM Akka Acctor. Я не знаю, где положить stash() и unstashAll(). У меня есть упрощенный пример ниже: import akka.actor.{ActorSystem, FSM, Props, Stash} tr

0зной

1ответ

akka unstashAll не работает

Я реализую актера с несколькими состояниями и используя Stash, чтобы не потерять сообщений. Мои состояния инициализируются (получают что-то из БД), запускают (обрабатывают запросы) и обновляются (обно

0зной

1ответ

Как делиться данными между участниками, которые должны быть кэшированы

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

0зной

1ответ

Akka (JVM) инициализирует регистратор перед ActorSystem

У меня есть приложение, которому необходимо вызвать некоторую внешнюю систему (чтобы дешифровать конфиденциальную информацию, чтобы она была коротка), прежде чем создавать конфигурацию, которую будет

0зной

1ответ

параметр Akka Streams + Akka Http Pass через поток

У меня есть следующий фрагмент кода: case class SomeClass(param1:String,param2:String,param3:String) val someClassActorSource: Source[SomeClass, ActorRef] = Source .actorPublisher[SomeClas

0зной

1ответ

Как отменить асинхронное вычисление в любое время?

Мне нужно выполнить сложные вычисления async и уметь прерывать их в любое время (из-за пределов вычислений). В текущей реализации используется scala.concurrent.Future для запуска вычислений. Однако, п

2зной

1ответ

Как сделать SQL от Akka?

Что такое идиоматический способ Akka выдавать SQL-заявления из приложения Akka? В частности, у меня есть конечная точка REST Akka Http, которая хочет выполнять команды SQL. Есть ли какая-то официальна