저널 지속성 플러그인을 사용하는 Azure에 Akka 응용 프로그램을 배포하려고합니다. 내가 사용해야하는 지속성 플러그인과 관련하여 제대로 된 조합을 찾을 수 없습니다. 몽고 드라이버 akka - 지속성 - 몽고와 푸른 문서 저장 : 지금까지 내가 들여다 akka - 지속성 - 몽고는 SSL을 지원하는 최신 반응성 몽고 버전과 호환되지 않기 때문에이 작동하
AtLeastOnceDelivery 영속 액터를 사용하고 있습니다. 우리는 엄청난 양의 확인되지 않은 메시지를 받고 있으며,이 수가 너무 클 경우 OutOfMemoryError가 발생합니다. 확인되지 않은 메시지가 확인 될 때까지 메모리에 보관하지 않고 디스크에 미확인 메시지를 보관하도록 AtLeastOnceDelivery 액터를 구성 할 수있는 방법이 있
장비로 발생하는 이벤트 (시간당 1 백만)를 처리하는 응용 프로그램을 작성하고 있습니다. 일부 이벤트는 시작 이벤트, 상태 (x-times) - 이벤트 및 종료 이벤트가 포함 된 집계됩니다 (그리고 긴 기간 (예 : 48 시간)). 기타는 즉시 처리 할 수있는 단일 이벤트입니다. 적어도 한 번 이벤트가 처리 될 것이라는 보장을 받으려면 나는 akka-per
나는 CQRS Akka 배우 앱의 질의면을하고 있습니다. 쿼리 배우는 클러스터 샤드로 설정되며 하나의 지속성 쿼리 스트림의 이벤트로 채워집니다. 내 질문은 : 클러스터 파편에있는 배우 중 하나가 그것을 복구하는 방법을 다시 시작하면? 전체 클러스터 샤드를 종료하고 모든 이벤트에 응답 하시겠습니까? 클러스터 샤드에있는 액터를 영속 액터로 만들고 쿼리 측에만
내 ES-CQRS 아키텍처에서 읽기 측을 구현하려고합니다. 이제 나는이 같은 지속적인 배우 있다고 가정 해 봅시다 : 이벤트가 지속됩니다 때 object UserWrite {
sealed trait UserEvent
sealed trait State
case object Uninitialized extends State
저는 최근에 ES 및 CQRS 모델에 대한 여러 동영상을 보았을뿐 아니라 AKKA 영속성에 대한 몇 가지 이야기를 보았습니다. 나는 그들이 무엇에 관한 것인지 알지만 실행될 실제 코드를 작성하는 데 문제가 있습니다. 나는 몇 가지 질문이 있습니다. 보기 및 이벤트 스택을 어떻게 통신해야합니까? 동일한 지속성 ID의 영구적 액터와 뷰 사이에 이벤트가 전달됩니
akka-persistence의 PersistenceQuery를 사용하여 물건을 관리하는 액터에 초기 상태를로드합니다. 시작시 정확히 한 번 재생하기를 원하지만 로그에 기록을 계속 보냅니다. 14:11:28.405 [rooms-akka.actor.default-dispatcher-4] DEBUG a.p.q.j.l.LiveEventsByPersistenceI
Akka가 제공에서 - 최소 한 번 메시지와 함께 영구 배우를 제공합니다 (link) 영구 FSM (link) 둘을 혼합 할 수 있습니까? 영구 상태 머신을 유지할 수 있기를 원하지만 스테이지 변경으로 인해 적어도 한 번만 메시지 배달 보장을 사용하여 다른 액터에게 메시지를 전송하는 이벤트를 발생 시키십시오.
CQRS에서 DB 호출이 필요한 명령의 유효성을 검사하는 가장 좋은 방법은 무엇입니까? 예를 들어, CommitOrder이라는 명령의 유효성을 검사하는 집계가 Order이고 충분한 재고가 없으면이 명령을 허용하고 싶지 않습니다. 이 경우 주문 처리 품목의 재고가 있는지 여부를 명령 처리기에서 어떻게 확인할 수 있습니까? 쓰기 측면에서 읽기 측면을 쿼리 할
우리는 Akka를 메모리 내장 메시지와 함께 사용 중이며 노드 클러스터링을 사용하지 않습니다. 우리는 couchbase를 충분한 공간을두고 처리 백엔드로 사용합니다. 노드가 작동하는 한 모든 것이 잘 작동합니다. 그러나 노드가 다운되면 모든 메모리 내 메시지가 손실됩니다. 우리는 작업자가 이상적 일 때 작업자가 큐에 500 개의 메시지를 요청할 때 작업 디