Описание тега akka-actor
1
ответ
Scala потоковая передача живого / растущего файла
Мое приложение Scala запускает внешний процесс, который записывает файл на диск. В отдельном потоке я хочу прочитать этот файл и скопировать его содержимое в OutputStream пока процесс не будет завершен и файл больше не будет расти. Есть несколько кр…
21 апр '18 в 23:32
1
ответ
Акка: как отключить актера, чтобы он не заканчивался
(отказ от ответственности: я менее начинающий с аккой) Предположим, у меня есть актер, вызывающий метод, который никогда не завершается (это крайний пример, вы можете подумать о вызове метода, который может завершиться в течение длительного времени …
07 ноя '17 в 18:55
0
ответов
ReflectiveDynamicAccess не содержит значений по умолчанию
У меня есть уже существующий код, который вызывает createInstanceFor метод akka.actor.ReflectiveDynamicAccess, Этот код по существу перебирает кучу значений конфигурации и создает экземпляры на основе конфигурации (имя класса указано в конфигурации)…
30 авг '18 в 18:50
1
ответ
Найти актера по номеру персистентности
У меня есть система, в которой есть актер на пользователя. Пользователи отправляют сообщения редко, но когда они это делают, они отправляют обычно не одно, а несколько. В настоящее время у меня есть карта, где я храню persistenceId -> ActorRef, К…
07 ноя '18 в 15:12
0
ответов
Как взаимодействовать с Akka Actors через Akka HTTP (Java)
Тема Я хотел бы взаимодействовать с Akka Actor через Akka HTTP. Идея состоит в том, чтобы создать систему, в которой HTTP-клиент вызывает метод HTTP-сервера Akka, который обрабатывает запрос к Akka Actor. Актер обрабатывает сообщение и отвечает обра…
19 янв '19 в 13:58
1
ответ
Как выполнить код после исключения в Scala, используя Try
У меня есть два актера, которые могут либо вернуть Result, который является логическим значением в моем случае, либо они могут выдать исключение, вот мой код val futureA: Future[Boolean] = ask(ActorA, MessageA(obj)).mapTo[Boolean] val resultA = Awai…
20 фев '19 в 09:29
0
ответов
Юнит-тестирование кафки потребителя актером с акка-стрим-кафкой
Я пытаюсь провести модульное тестирование актера, который использует сообщения от kafka, используя абстракцию akka streams kafka. У моего актера есть два конструктора: основной, который используется в тестировании, и дополнительный, который использу…
27 ноя '17 в 14:13
1
ответ
Сериалы-привязки акки тоже ограничены?
Возможно ли дополнительно квалифицировать сериализацию-привязки? Тип времени выполнения кажется слишком ограниченным. например, у меня есть trait PersistentExecutorProtocol[Payload] extends Serializable { sealed trait Event extends Serializable case…
01 июн '17 в 18:47
1
ответ
Получение ошибки при компиляции исходного кода актера akka с использованием sbt
Я хочу получить исходный код akka-actor v 2.4.17 и скомпилировать его на моей машине с Windows. Я скачал исходный код из местоположения ниже. https://github.com/akka/akka/tree/v2.4.17 После загрузки всего исходного кода установил sbt на мою машину, …
18 янв '18 в 18:01
1
ответ
Акка статическое использование
У меня есть простая система актера с конфигурацией по умолчанию. У меня есть расширенный класс актера class Test extend Actor { def receive: Receive = { case Foo(collection) => sender ! extract(collection) } private def extract(c: List[FooItem]):…
26 апр '17 в 16:56
3
ответа
Когда создавать актер Akka
У меня есть служба REST, которая обслуживает только один запрос POST. Я хочу использовать актера для обработки запроса. Однако я не знаю, должен ли я создать одного актера и получить все запросы, используя этот актер, или мне нужно создавать актера …
23 окт '16 в 13:01
1
ответ
Проверьте, существует ли актер в кластере akka
Я столкнулся со сценарием, в котором мне нужно проверить, существует ли конкретный актер или нет, что можно сделать с помощью метода ActorSystem.actorSelection, указав путь к актеру.Однако этот метод работает правильно, когда такой субъект существуе…
23 янв '18 в 09:39
1
ответ
Должен ли я каждый раз создавать нового актера или создавать его как статический ранее?
Я использую akka.net и может произойти утечка памяти, потому что она стоит много памяти и постоянно увеличивается Должен ли я каждый раз создавать нового актера или создавать его как статический ранее?
04 авг '17 в 11:31
2
ответа
АККА - как заблокировать создание актера, если его имя не уникально в кластере
Я пытаюсь заблокировать возможность присутствия в системе актеров с одинаковым именем (они находятся на разных путях, поэтому InvalidActorNameException не будет брошен) application.conf: someactor { akka.remote.netty.tcp.port = 6405 akka.cluster.aut…
03 янв '17 в 16:09
0
ответов
Параллельный запуск этапов Akka Streams значительно увеличивает нагрузку на память
Я пытаюсь реализовать поток Akka, который читает кадры из видеофайла и применяет классификатор SVM для обнаружения объектов в каждом кадре. Обнаружение может выполняться параллельно, поскольку порядок видеокадров не имеет значения. Моя идея состоит …
20 янв '17 в 12:46
0
ответов
Обращаться к Акке по запросу с актерами?
ActorRef actor = ...; Flow<HttpRequest, HttpResponse, NotUsed> flow = Flow .of(HttpRequest.class) .via(Flow.fromSinkAndSource( Sink .actorRef(actor, "COMPLETED"), Source .actorRef(4, OverflowStrategy.fail()) .mapMaterializedValue(sourceActor -…
15 июн '17 в 10:37
0
ответов
Akka- файл журнала перенаправления между дочерними актерами
Я в настоящее время использую свойство log4j RollingFileAppender чтобы перенаправить журналы в файл, а имя файла журнала определяется аргументом процесса: log4j.properties: log4j.appender.file=org.apache.log4j.RollingFileAppender log4j.appender.file…
06 апр '17 в 08:27
1
ответ
Сервер Ebean по умолчанию является нулевым, когда модуль запуска называется [Play Framework]
Я использую Play Framework 2.5.10 с sbt-play-ebean 3.0.0. Моя проблема Мне нужно настроить актеров Akka для каждого объекта из одной из моих моделей при запуске приложения. Единственный официальный способ сделать это - зарегистрировать модуль запуск…
27 фев '17 в 10:40
1
ответ
akka actor текущее имя функции приема
У меня есть простой актер с 2 поведением package com.hello import akka.actor.{Actor, ActorLogging} case object Ping class Hello extends Actor with ActorLogging { import context._ def receive: Receive = behaviorFoo self ! Ping def behaviorFoo: Receiv…
14 ноя '17 в 17:26
1
ответ
Как проверить размер тайника в актере
Я реализовал скрытие в актере, используя метод stash в Akka actor, но теперь мне нужно просмотреть его размер (т.е. нет сообщений в stash). Есть ли способ сделать это? Ниже приведены метод и документация к нему - /** * Adds the current message (the …
25 июл '18 в 06:57