12
ответов

AKKA-Java NullPointerExeption [дубликат]

Я делаю первые шаги в AKKA, следуя этому руководству: есть тестовый файл J-unit и класс для Актера. Вы можете увидеть весь код по ссылке, это всего лишь куча строк. Однако тест не удается ...
вопрос задан: 26 May 2016 16:15
3
ответа

Есть ли способ получить сопоставляемый элемент, когда генерируется исключение akka streams?

Я хочу иметь возможность регистрировать определенные атрибуты сопоставляемого элемента, если возникает исключение, поэтому мне было интересно, есть ли способ получить сопоставляемый элемент при создании исключения akka ...
вопрос задан: 17 January 2019 15:43
2
ответа

Получить Seq сущностей из ответа akka http на основе массива json

Я пытаюсь использовать Flow как http-клиент Akka, и у меня возникли проблемы с получением Seq объектов класса case из массива json в ответе http. HTTP-ответ: {"bars": [], "foos": [{"id": ...
вопрос задан: 20 January 2019 16:23
1
ответ

Полнофункциональное планирование Cron потоков akka

В потоках akka можно сделать следующее: Source.tick (0.seconds, 15.seconds, «Hello»), и ваш поток будет получать тиковый элемент «Hello» каждые 15 секунд. То, что я ищу, это ...
вопрос задан: 5 March 2019 19:04
1
ответ

Поведение Akka Supervision по умолчанию

Я пытаюсь узнать нашу стратегию надзора Акки. Когда у меня есть код, подобный приведенному ниже, я получаю java.lang.ArithmeticException: / с нулевым регистром объекта Create Children case class ...
вопрос задан: 17 January 2019 02:01
1
ответ

Как часто мы должны использовать фьючерсов и актеров? Есть альтернативы? [закрыто]

Я решил создать физический движок с помощью scala, используя параллелизм. Я знаю, что для большого числа вычислений можно распараллелить (что важно для оптимизации вещей). Однако я знаю ...
вопрос задан: 16 January 2019 07:58
1
ответ

Как исправить Dropping Close, так как соединение SSL уже закрывает ошибку в спрее

Я звоню в API, но большую часть времени получаю сообщение об ошибке: «Отключение закрытия, так как соединение SSL уже закрывается» и «Преждевременное соединение закрывается (сервер, похоже, не ...
вопрос задан: 20 March 2018 14:35
0
ответов

Акка Реквизит существующего Актера

Я новичок в мире Play / Akka / Actor. Я реализую сервис WebSocket, который ожидает получить реквизит от созданного актера. вернуть WebSocket.withActor (actorRef - > service.handle (...
вопрос задан: 30 June 2019 04:47
0
ответов

Настройки таймаута HttpClient Akka

Я пытаюсь реализовать HTTP-клиент в своем приложении Akka для использования стороннего API. Я пытаюсь настроить время ожидания и количество повторных попыток в случае сбоя. Это ниже ...
вопрос задан: 27 March 2019 20:51
0
ответов

Ошибка при попытке сделать постоянным действующим лицом требуемый почтовый ящик с обязательной очередью сообщений

Я пытаюсь следующее: класс ClientActor (stockActor: ActorSelection, paymentActor: ActorSelection) расширяет PersistentActor с AtLeastOnceDelivery с akka.actor.ActorLogging с ...
вопрос задан: 17 March 2019 23:16
0
ответов

Datadog представляет странную встречную строку Камона

Я использую Камона, чтобы собрать мои метрики, и Датадога, чтобы представить их. В своем приложении playframework я просто добавил счетчики для некоторого статуса, например: Kamon.metrics.counter ("status-counter", tags = Map ("status" ...
вопрос задан: 26 February 2019 21:56
0
ответов

Запуск задания в автономном режиме Apache Flink на Zeppelin У меня есть эта ошибка & ldquo; TooLongFrameException: скорректированная длина кадра превышает & ldquo;

Я пытаюсь запустить простую работу в Apache Flink с помощью Zeppelin. Я создал Docker-контейнер с запущенным zeppelin 0.8.0. В этом же контейнере у меня работает apache flink 1.6.1. Когда я бегу ...
вопрос задан: 18 January 2019 16:13
0
ответов

Хороший вариант использования для Akka [закрыто]

Я слышал много восторженных отзывов об инфраструктуре Akka (сервисной платформе Java / Scala), но до сих пор не видел много реальных примеров использования, для которых это было бы полезно. Так что мне было бы интересно услышать ...
вопрос задан: 23 July 2017 23:09
0
ответов

Разница между кластеризацией и удаленным взаимодействием в Akka

Я разработал свое приложение с Akka на одной JVM. Теперь я хочу распределить рабочую нагрузку по многим машинам. Я начал читать документацию и запутался. Есть два способа ...
вопрос задан: 5 November 2014 14:56
0
ответов

Блокировка звонков в Akka Actors

Как новичок, я пытаюсь понять, как работают актеры. И из документации, я думаю, я понимаю, что актеры - это объекты, которые исполняются в режиме синхронизации, а также, что выполнение акторов может ...
вопрос задан: 13 November 2013 02:20