akka — все вопросы

1ответ
4 голоса
Слишком много одновременных запросов с Akka и фьючерсами
Мой сценарий примерно такой. У меня есть вектор, состоящий из большого количества отчетов, которые необходимо отправить с помощью вызова API api. Я использую Futures.traverse (вектор, упомянут
1ответ
4 голоса
Завершается ли прибытие после сообщений от умирающего актера?
У меня есть актер, порождающий временных дочерних акторов для некоторых заданий, родительский субъект хранит информацию о каждом действующем субъекте на простой карте, когда ребенок сообщает о завер
2ответа
4 голоса
Как задержка планировщика акки?
Я написал актера, используя планировщик каждые 5 миллисекунд для назначения метки времени полю. И в ходе теста я обнаружил, что результат (System.currentTimeMillis() - timeField) составляет не ме
1ответ
4 голоса
Использование платформы Scala Akka для блокировки вызовов CLI
Я относительно новичок в Akka & Scala, но я бы хотел использовать Akka в качестве универсальной платформы для сбора информации из различных веб-инструментов и команд cli. Я понимаю общий прин
1ответ
4 голоса
Как очистить очередь мертвых писем Актера
У меня есть сценарий использования, в котором я хотел бы очистить очереди мертвых писем моих актеров Akka. Мой локальный актер общается с удаленным, периодически отправляя ему некоторые данные. Я
2ответа
4 голоса
Пример Java для отправки неблокирующего http-запроса от AKKA
В документации АККА написано, что    ... Актеры не должны блокировать (то есть пассивно ждать, занимая поток) на некотором внешнем объекте, который может быть блокировкой, сетевым сокетом и т. д.
2ответа
4 голоса
Java - блок в вызове метода конструктора
// allows passing in arguments to the MyActor constructor ActorRef myActor = system.actorOf(new Props(new UntypedActorFactory() { // public UntypedActor creat
1ответ
4 голоса
Как избежать ошибки "пропущенного типа" при объединении частичных функций
В настоящее время я изучаю Scala & Акка и разработка тестового приложения для него. В этом приложении почти все участники регистрируют необработанные сообщения для простоты отладки: import
3ответа
4 голоса
Как изменить будущий тайм-аут с помощью игровой среды 2.1.0
Я звоню в веб-сервис, используя Play Framework 2.1, который занимает больше 10 секунд из-за этого я всегда получаю следующую ошибку: play.api.Application$$anon$1: Execution exception[[TimeoutExcep
2ответа
4 голоса
Зная, когда актеры Акка закончили
Несколько человек вместе со мной работают над проектом, который пытается найти лучший способ решить эту проблему. Кажется, это должно быть стандартным делом, которое нужно регулярно, но по какой-то
2ответа
4 голоса
Зная, когда актеры Акка закончили
Несколько человек вместе со мной работают над проектом, который пытается найти лучший способ решить эту проблему. Кажется, это должно быть стандартным делом, которое нужно регулярно, но по какой-то
1ответ
4 голоса
Akka AssociationError - адрес локальной сети против локального
Я новичок в akka и пытаюсь получить пример для работы между несколькими JVM. Я работаю с примером, показанным здесь , но сталкиваюсь проблема. В конце журнала, приведенного ниже, вы можете увидеть,
3ответа
4 голоса
Могу ли я использовать TestEventListener от Akka, не загрязняя результаты теста через STDOUT?
В рамках моего тестирования я использую EventFilter и TestEventListener для прослушивания сообщений журнала. Тем не менее, из-за этого в моей командной строке происходит массивный поток ... который
2ответа
4 голоса
RemoteActorRefProvider ClassNotFound
Я изо всех сил пытаюсь настроить удаленных актеров в Scala. Я использую Scala 2.10.2 и Akka 2.2.1. Я компилирую, используя [для краткости я сократил пути в аргументе classpath]: $ scalac -class
1ответ
4 голоса
Запуск akka в задаче сборки SBT: эталонная конфигурация неожиданно отсутствует
Я пытаюсь выполнить довольно простой HTTP-запрос POST в задаче, которую я написал для своей сборки SBT, и, видя, что у SBT, похоже, нет помощников для этого, я решил использовать спрей-клиент для вы
1ответ
4 голоса
Как я могу проверить, как Akka стал /не стал переходом?
Есть ли рекомендуемый способ проверки того, что актер правильно изменил свое поведение с помощью команды make? Одна из причин, по которой я предпочитаю использовать FSM, заключается в том, что я могу
1ответ
4 голоса
Akka Event Bus: найти неиспользованные события в канале?
Если актер запускается и подписывается на канал в шине событий Akka, есть ли у актера возможность использовать события, которые уже были отправлены на канал, но не были использованы другим актером?
2ответа
4 голоса
Порядок вставки списка на основе порядка другого списка
У меня есть проблема сортировки в Scala, которую я, безусловно, мог бы решить с помощью грубой силы, но я надеюсь, что есть более умное /элегантное решение. Предположим, у меня есть список строк в п
1ответ
4 голоса
Akka Persistence Cassandra с Akka 2.3.0, создающий роковое EOFException при использовании с Play 2.2.1
Есть идеи, почему я получаю следующую ошибку после добавления Akka в мои библиотечные зависимости и выполнения задачи test? Uncaught error from thread [reactivemongo-akka.actor.default-dispatcher-
2ответа
4 голоса
Сериализация rx-java, наблюдаемая по сети
Я пытаюсь сериализовать подписку для отправки по сети. Я использую Scala, и делаю что-то вроде этого: observable.materialize.subscribe{ n : Notification => sendToNetwork(n)} Однако я получа
1 2 3 4 5

Популярные теги

security × 330linux × 316macos × 2827 × 268performance × 244command-line × 241sql-server × 235joomla-3.x × 222java × 189c++ × 186windows × 180cisco × 168bash × 158c# × 142gmail × 139arduino-uno × 139javascript × 134ssh × 133seo × 132mysql × 132