akka-persistence

1열

2답변

시스템이 다시 시작되면 context.children() 호출은 특정 부모에 대해 0 개의 자식을 반환합니다. 다시 시작하기 전에 context.children()은 부모가 가진 자식의 실제 개수를 반환했습니다. 누군가가 나를 다시 시작한 후 부모를위한 children ActorRef를 어떻게 얻을 수 있는지 알려주십시오. 내 사용 사례는 다음과 같습니다

2열

1답변

Akka Persisence Query Read Journal이 내 이벤트를 검색하지 않는 이유는 무엇입니까?

Akka 지속 쿼리를 이해하는 데 문제가 있습니다. 특히 예상대로 작동하지 않으므로 eventsByTag 메서드가 문제가됩니다. 내 메인 클래스에서 특정 태그로 유지되는 모든 이벤트를 수신하기 시작하는 클래스를 호출합니다. class CassandraJournal(implicit val system: ActorSystem) { def engageStre

1열

1답변

테스트 코드에서 prod 코드보다 다른 application.conf를 사용하는 방법은 무엇입니까?

메신저가 scalatest로 PersistentActor를 테스트하려하지만 application.conf 대신 application-test.conf와 같은 것을 사용하도록 테스트 코드를 지정하는 방법을 모릅니다 (메모리 저장소에있는 이벤트에 대해 leveldb 저장소를 변경하려고합니다). 이 작업을 수행하는 편리한 방법이 있습니까?

0열

1답변

Akka.net - 새 개체를 만들 때마다 모든 저널 데이터를로드합니다.

Akka.NET에서 새 개체 유형을 만들 때마다. 해당 유형의 전체 저널은 생성자에서로드되는 내 시험이 저널 public sealed class CreateContactCommand : AuditCommandBase<Contact, CreateContactEvent>, ICommand<Contact, CreateContactEvent> {

0열

1답변

액터가 akka-persistence에서 타임 아웃을 요청합니다.

이 오픈 소스를 사용하여 MongoDb에 의해 지원되는 akka-persistence와 함께 "hello-world"예제를 시도했습니다. https://github.com/scullxbones/akka-persistence-mongo/tree/master/rxmongo/src. 아래는 제 코드입니다. 그러나 응용 프로그램을 실행할 때 시간 초과를 묻는 메시

2열

1답변

akka 클러스터 인식 라우터 및 akka 클러스터 샤딩의 사용 사례가 다릅니 까?

클러스터 인식 라우터 : 여기 val router = system.actorOf(ClusterRouterPool( RoundRobinPool(0), ClusterRouterPoolSettings( totalInstances = 20, maxInstancesPerNode = 1, allowLocalRoutees = f

1열

1답변

akka-persistence를 사용하여 sql 데이터베이스를 대체하는 이유는 무엇입니까?

는 Clojure의 하스켈에서 SQL 데이터베이스를 대체 할 수있는 방법이 있습니다 http://www.datomic.com/ (Clojure에) 내가 akka를 사용하여 스칼라에서 그렇게하기위한 라이브러리를 찾을 수 없습니다 그러나 https://github.com/dmbarbour/haskell-vcache https://hackage.haskell.o

2열

1답변

Akka Persistence Cassandra 데이터베이스를 복사하는 방법

우리는 Lagom 기반의 프로젝트에 여러 개의 마이크로 서비스가 있으며 각 프로젝트에는 자체 Cassandra 키 공간이 있습니다. 생산 데이터를 qa 및 dev 환경으로 복사해야합니다. 전통적인 데이터베이스에서는 단순히 모든 프로덕션 데이터를 내보내고 다른 환경으로 가져옵니다. Akka Persistence와 어떻게 다른가? 나는 (즉, 생산 백업에서 멀

2열

1답변

Akka-Persistence : 스냅 샷을 가져 오는 방법

akka-persistence에서 이전 스냅 샷을 어떻게 쿼리 할 수 있습니까? SnapshotStore에는 개인적으로 사용할 수 있지만 다른 방법으로는 호출 할 수없는 메시지가 LoadSnapshot 있습니다. 는 snapshotter의 인터페이스가 ->loadSnapshot 하지만이 배우에 콜백을 제공하고, 내가 필요하지 않습니다. /**

1열

1답변

기본 akka 찾기 배우와 상태

이것은 akka에 관한 몇 가지 기본적인 질문입니다. 나는 akka에서 완전히 녹색이므로 어떤 충고도 환영받습니다. 수백만 명이 아니라 수천 명의 사용자가있는 애플리케이션이라고 가정 해보십시오. 도메인 모델은 각 사용자가 한 국가 내의 한 지역에 위치하는 즉, 한 국가에는 여러 지역이 있고 하나의 지역에는 여러 사용자가있는 계층입니다. 나는 akka에서 정