Результаты поиска по запросу "akka"
с помощью инъекции guice с актером выбрасывает нулевой указатель
Я получаю исключение нулевого указателя при внедрении поля сервера, который запускается как актер akka. Вводная часть: private ActorRef myActor = Akka.system().actorOf( new Props(Retreiver.class)); @Override public void onStart(Application app) ...
Возникли проблемы с планировщиком Akka 2.1.2 («система» не распознана)
Я пытаюсь запустить очень простой цикл повторяющихся функций, в соответствии с этими примерами: http://doc.akka.io/docs/akka/2.1.2/scala/scheduler.html [http://doc.akka.io/docs/akka/2.1.2/scala/scheduler.html] Код: import akka.actor.Actor ...
Использовать поток TCP и перенаправить его на другой приемник (с помощью Akka Streams)
Я пытаюсь перенаправить / переслать поток TCP на другой Sink с Akka 2.4.3. Программа должна открыть сокет сервера, прослушать входящие соединения и затем исп...
Акка Фьючерс Исключения
Что происходит, когда актер будущего выдает исключение? Согласно документации Akka на http://doc.akka.io/docs/akka/snapshot/scala/futures.html [http://doc.akka.io/docs/akka/snapshot/scala/futures.html]: Не имеет значения, завершает ли Актер или ...
Как я могу разобрать параметры запроса получения в спрей-маршрутизации?
Вот как выглядит фрагмент кода
Akka - повторная отправка сообщения «взлом»
В официальномАкка 2.0.4 документы [http://doc.akka.io/docs/akka/2.0.4/scala/actors.html#Restart_Hooks]это говорит: Перезапуск актера заменяет только фактический объект актера; перезапуск не затрагивает содержимое почтового ящика, поэтому ...
Создание основанного на времени чанкинга Enumeratee
Я хочу создать Enumeratee для Play 2, который принимает значения и выводит их, разбивая их на куски, каждыйx секунды / миллисекунд. Таким образом, в многопользовательской среде веб-сокетов с большим количеством пользовательского ввода можно ...
Акка Килл против Стоп против Яда Таблетки?
Вопрос новичка Акки - ЯЯ читаю над Akka Essentials, может кто-нибудь объяснить, в чем разница между Akka Stop / Poison Pill и Kill? Книга предлагает только н...
Как я могу получить абсолютный удаленный URL-адрес актера изнутри актера?
Я хочу сделать что-то подобное. Актер А: actorB ! "info" def receive()={ case _ => { println("Remote address is "+ _) } } Актер Б: (это развернуто удаленно) def receive()={ case "info" => { sender tell self.path.address.toString } }Я хочу, ...