akka

2열

1답변

으로 선언 된 lazy val에서 패턴 일치가 가능합니까? lazy val kafkaProducer: Try[producer.KafkaProducer[Array[Byte], String]] = Try(kafkaProducerSettings.createKafkaProducer()) ... kafkaProducer.get match { case S

0열

2답변

Lagom-Scala의 일괄 삽입 Cassandra readside

Google에서 검색했지만 Cassandra 읽기 측면 문서 페이지 이외의 링크가 없습니다. 그래서, 배치 행 삽입을 위해 Akka-Cassandra 패키지에 이미 포함 된 API 또는 함수가 있는지 묻고 싶습니다. 또는 여러 행 삽입을 위해 삽입 코드를 여러 번 호출해야합니다. 참고 : - 여러 이벤트를 삽입하는 것에 대해 묻지 않고 일부 json 데이터

2열

1답변

TestActorRef로 만든 액터를 때때로 해석 할 수 없습니다.

액터가 TestActorRef.apply()를 사용하여 생성 된 경우 Future 내에서 actorSystem.actorSelection.resolveOne을 호출하여 해결되지 않을 수 있습니다. TestActorRef의 문서에서는 단일 스레드 환경에서 사용할 수 있지만 다음 테스트가 실패하는 특정 이유가 무엇인지 궁금합니다. Akka 버전 : 2.4.16

2열

2답변

왜 Source.tick은 HttpRequests가 끝난 후 멈 춥니 까?

akka 스트림과 akka HTTP를 사용하여 3 초마다 api를 폴링하는 스트림을 생성하고 결과를 JsValue 객체로 비 정렬 화하고이 결과를 액터로 보냅니다. 다음 코드에서 볼 수 있듯이이 작동 // Source wich performs an http request every 3 seconds. val source = Source.tick(0.sec

0열

1답변

Akka에서 TestActorRef가 기존 ActorRef를 감싸는 방법?

akka 배우 시스템을 테스트하는 동안 여러 개의 중첩 된 액터로 인스턴스화합니다. 엔트리 포인트로서, 부모 액터는 중첩 된 자식 액터 트리를 생성합니다. 프로덕션 트리와 비슷하지만 H2 db 소스의 테스트 데이터가 들어 있습니다. 데이터 불일치로 인해 다른 시스템에서 개별적으로 액세스하거나 인스턴스화 할 수없는 전체 시스템의 일부 (즉, 단일 액터 상태라

0열

1답변

미래에 의존하는 배우 AKKA 배우들

미래에 달려있는 배우에 대한 간단한 테스트를 작성하려고합니다. 여기에 완료하려면 import akka.actor.{ Actor, ActorSystem, Props } import akka.testkit.{ ImplicitSender, TestKit } import org.scalatest.{ BeforeAndAfterAll, WordSpecLike }

0열

1답변

단위 테스트 Akka 액터를 사용하는 구성 요소

우선, 나는 Akka 액터의 단위 테스트 방법을 묻지 않을 것입니다. 나는 그 기술을 알고 있습니다. 내 문제는 약간 다릅니다. 저는 Scala 프로그램을 개발 중입니다.이 프로그램은 Akka 액터를 사용하지 않고 client이라고 부릅니다. 그러나이 프로그램은 라이브러리를 사용하므로이 인터페이스를 Akka Actor를 사용하여 구현 한 server이라고합

1열

2답변

akka에서 수퍼 액터의 동작을 확장하는 방법

akka 액터를 사용하여 CRUD 연산을 구현하고 싶습니다. 나는 akka의 새로운 개념이므로 akka 배우의 기본 설계를 모릅니다. 여러 하위 액터에서 akka 배우의 행동을 공유하고 싶습니다. 전나무 나는 학생, 교사 및 다른 실체를 저장하고 지우고 싶습니다. 나는 두 DAO 추상 삭제 방법 원하는 TeacherDao.scala class Teacher

1열

1답변

akka.Source의 두 번째 유형 매개 변수의 용도와 의미는 무엇입니까

akka.Source의 두 번째 유형 매개 변수의 용도와 의미는 무엇입니까? 샘플 코드 : - def stream: ServiceCall[Source[String, NotUsed], Source[String, NotUsed]] 만큼 코드에 따르면 지금은 기본적으로 두 번째 유형 매개 변수가 akka.NotUsed로 설정하도록 보았다. 그러나 나는 그것의

1열

1답변

Play 프레임 워크가 Akka 스트림을 닫지 않는 이유는 무엇입니까?

액터는 웹 소켓에 연결된 아카 스트림을 초기화합니다. 메시지를 보낼 수있는 Source.actorRef을 사용하면 메시지가 webSocketClientFlow에 의해 처리되고 Sink.foreach에 의해 소비됩니다. 이것은 (akka docs에서 파생 된) 다음 코드에서 볼 수있다 : class TestActor @Inject()(implicit ec: