akka

0зной

1ответ

Я использую akka http. В моем API слое я определил следующие классы: sealed abstract class ApiResponse[A](val content: A, val code: Int) final case class Success[A](override val content: A, override

1зной

1ответ

Почему актеры не могут выполнить всю работу, хотя я создал 10000 из них?

Я создаю 10000 актеров и отправляю сообщение каждому, но кажется, что система akka не может завершить всю работу. , когда я проверяю состояние резьбы, все они находятся в TIMED_WATIING. Мой код: class

0зной

1ответ

Как использовать автоматический выключатель Akka с CompletableFutures?

Я использую Play! 2.5 (Java) и Akka. Вот моя проблема: я пытаюсь вызвать внешнюю службу с помощью WSClient и хотел бы, чтобы она была за выключателем Akka. Код, показанный ниже, не работает должным об

4зной

3ответ

Akka Streams: Как настроить пропускную способность/ограничение скорости в системе из 2 связанных потоков?

Допустим, у меня есть печь для пиццы и линия пиццы, которую мне нужно испечь. Моя духовка имеет только возможность выпекать 4 пиццы за раз, и разумно ожидать, что в течение дня в очереди всегда будет

0зной

2ответ

Akka FSM matchEvent implemantation

Я пытаюсь понять AKKA FSM "matchEvent": public final <ET> FSMStateFunctionBuilder<S, D> matchEvent(Class<ET> eventType, TypedPredicate2<ET, D> predicate, Apply2<ET, D, State<S, D>> apply) { retu

2зной

1ответ

Akka: когда это безопасно отправить сообщение

я создаю актер через: system.actorOf(Props(....)) или system.actorOf(SmallestMailboxPool(instances).props(Props(....))). Я обычно блокировать поток вызывающего system.actorOf до сих actorSelection

0зной

1ответ

Akka + Camel + Контекст-провайдер

Дорогие мастера Camel/Akka/Netty! Я создал UntypedConsumerActor, который потребляет соединение TCP: public class TcpEndpoint extends UntypedConsumerActor { private static final Logger log = Logg