나는 다음과 같은 코드가 있습니다 작동하지 않습니다 "dead letters"메시지가 표시되어 다시 시작하지 않았습니다. OneForOneStrategy이 호출되지 않는 이유는 무엇입니까? 전체적으로 OneForOneStrategy 오버라이드를 제거 할 수있는 방식으로 이상하고 프로그램 동작에 변경 사항이 없습니다.
PoisonPill 또는 context.stop()에 있는지 여부에 관계없이 액터에서 stop 이벤트를 캡처 할 수 있습니까? 본질적으로, 저는 배우가 "dieing"이벤트 루프가되도록하고 싶습니다. 그래서 물건을 닫을 때까지 기다릴 수 있고, 물건이 닫을 때 context.stop (self)를 호출하면 정상적으로 닫힙니다. 이것은 순환 적으로 보인다.
libGDX에서 scene2D를 배우고 nullPointerException을 계속 실행하는 데 도움이되는 작은 프로젝트를 시작했습니다. 내 목표는 플레이어가 동작 시퀀스를 사용하여 점프하도록하는 것입니다. 내 문제는 플레이어가 뛰어 내린다는 것이지만, 일단 게임이 다시 쓰러지면 떨어집니다. 제가 생각하기에 문제를 일으키는 코드의 비트를 포함 시켰습니다.
RabbitMQ와 통합해야하는 백엔드 스칼라 애플리케이션이 있습니다. 백엔드 스칼라 앱은 장기 실행 작업을 비동기 적으로 실행합니다. 작업을 실행하기위한 메시지는 웹 클라이언트가 RabbitMQ에 대기시킵니다. 그런 다음 백엔드 어플리케이션은 이러한 각 메시지를 사용하여 해당 장기 실행 태스크를 실행합니다. Scala 앱이 RabbitMQ의 메시지를 직접
저는 스칼라에서 Akka 배우를 배우기 시작했습니다. 필자가 알고있는 것은 액터가받은 메시지가 액터의 사서함에 대기하고 한 번에 하나씩 처리된다는 것입니다. 메시지를 한 번에 하나씩 처리하면 동시성 문제 (경쟁 조건, 교착 상태)가 완화됩니다. 그러나 액터가 메시지와 관련된 작업을 수행하기 위해 미래를 창출한다면 어떻게 될까요? 미래가 비동기이기 때문에 액
파이썬으로 작성된 몇 가지 분석 코드가 있습니다. 현재 Storm을 사용하여 스트림을 처리하고 있습니다. Storm은 메시지 직렬화를 사용하여 파이썬 코드를 호출 할 수 있으므로 Storm 볼트에서 Java/Scala의 Python 코드를 호출합니다. 나는 배우 모델의 파이썬 구현 인 Pykka을 발견했습니다. Akka 배우로부터 파이썬 코드를 호출 할 수
메시지가 말 또는 질문인지 확인할 수있는 방법이 있습니까? 사용 사례 : 나는 도서관이 배우의 외부에서 사용하고 메시지에 사용되는 알려줍니다 사례를보고 있어요 . 라이브러리는 성공/실패에 대한 결과로 회신하기 때문에 사용법에서는 신경 쓰지 않고 배우가 아닌 컨텍스트에 메시지를 전달하고 수신합니다. 기본적으로 메시지는 정상적으로 작동하지만 메시지를 기록하는
libGdx 초보자는 여기에 있습니다. 저는 Tic-Tac-Toe 게임을 만들고 있습니다. 저는 십자가와 원을위한 이미지 인 액터를 정의했습니다. 나는 클릭하는 액터를 그리도록 이벤트 리스너를 추가했습니다. 이제 문제는 다른 위치에 같은 액터를 그릴 때 다른 액터를 그릴 때 움직이는 것입니다. fieldImg.addListener(new ClickListe
와일드 카드로 actorSelection을 호출하고 일치하는 액터가 없으면 응답으로 ActorIdentity(None,None)이 발생하지만 아무 일도 일어나지 않습니다. 정상적인 상황입니까 아니면 여기에 뭔가 빠졌습니까? class A extends Actor {
val b = context.actorOf(Props[B], "test")
나는 미래의 결과를 기다리는 배우가 있습니다. 미래의 onComplete를 호출하면 컴파일러 오류가 발생합니다 error: constructor cannot be instantiated to expected type [scalac] found : akka.actor.Status.Success [scalac] required: scala.util.Try[It