Результаты поиска по запросу "akka"
Как использовать составную черту с актерами Акки?
Я пытаюсь реализовать черту Pub / Sub, чтобы смешивать ее с другими актерами akka, используя черту стека. Вот что я придумал: trait PubSubActor extends Actor { abstract override def receive = super.receive orElse { case Subscribe(topic) => /* ...
Сбой самого масштабного, когда актер akka выдает исключение за пределами тестового потока
Я несколько раз сталкивался с ситуацией, когда я проверял Актера, и Актер неожиданно выдает исключение (из-за ошибки), но тест все равно проходит. Теперь в большинстве случаев исключение в Actor означает, что то, что проверяет тест, не будет ...
Поэтому я бы сказал, что это максимальное количество элементов, которые можно обрабатывать без регулирования. Обработанный "в то же время" никогда не будет точным определением в потоке :)
def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]лиmaximumBurst означает количество элементов, которые могут быть обработаны одновременно?
github.com/chaostheory/jibenakka
шал много бреда оAkka [http://akka.io/]фреймворк (сервисная платформа Java / Scala), но до сих пор не было много реальных примеров использования, для которых это было бы хорошо. Поэтому мне было бы интересно услышать о вещах, которые разработчики ...
Затем вы можете использовать unmarshaller, передавая его в директиву параметров:
отаю над REST-сервисом, используя Akka HTTP (в Scala). Я хотел бы, чтобы параметр, который передается в запрос http get, был преобразован в тип ZonedDateTime. Код работает нормально, если я пытаюсь использовать String или Int, но не работает с ...
Я не установил для master значение local [n], но получил то же исключение.
от вопрос уже есть ответ здесь: Почему не удается присоединиться к «java.util.concurrent.TimeoutException: время ожидания фьючерса истекло после [300 ...
были предоставлены для таких случаев, когда мы знаем и полагаемся на конечную точку HTTP.
я есть топология akka-streams, где я делаю вызов POST, используя akka-http. Я получаю следующее сообщение об ошибке при отправке запроса на незащищенный сервер (с самозаверяющими сертификатами). Это внутренний сервер, так что я в порядке с точки ...
Поддерживает ли Akka обмен сообщениями в процессе без сериализации объектов?
Нужно использовать Akka Actors для передачи событий между потоками Java в одной и той же JVM. Некоторые из этих событий содержат большие объекты (10-100 МБ). Я хочу избежать сериализации этих объектов при экономии места в памяти, передавая только ...
Akka Routing: отправка ответа на маршрутизатор заканчивается как мертвые буквы
Я играю с Actor Routing, и я не могу отправить ответ обратно маршрутизатору, чтобы другой актер из списка маршрутизации мог это заметить, чего я здесь не вижу;) Я использую: sender.tell([Message], context.parent)чтобы ответить маршрутизатору, ...
член, вам нужно изменить свое заявление на
орая проблема формата, когда я пытаюсь процитировать код, поэтому вот изображение :( описание изображения здесь [https://i.stack.imgur.com/4GAYi.jpg] import akka.actor.{Actor, ActorSystem, Props} case class Number(n: Int) case class String(s: ...