Lagom에서 "만료 후"부작용을 구현하는 방법은 무엇입니까?

Question

나는 처음 Lagom + CQRS/이벤트 소싱 접근 그리고 난 같은 동작을 구현하고 싶습니다 :

1. 서비스 호출이 (A REST API 호출을 통해 예를 들어) 실행
2. 을 명령이 실행되고 상태를 변경시키는 이벤트를 트리거합니다 (예 : 어떤 종류의 타이머를 시작 함).
3. 미리 정의 된 간격 후에 타이머가 만료되어 타이머를 무효화하기 위해 상태를 변경하기 위해 새 이벤트를 트리거해야합니다 (다른 외부 명령없이).

처음 두 단계는 간단하지만 TimerStartedEvent를 트리거하고 상태를 변경하면 고정 된 시간이 지나면 일정을 어떻게 "예약합니까"? 세 번째 단계는 어떻게 구현합니까?

Answer 1

실현 가능성 (실제로는 online-auction-scala sample code 자체)을 발견했습니다.

Lagom은 Akka 위에 구축 되었기 때문에 ActorSystem을 주입하므로 나중에 system.scheduler.schedule 호출을 사용하여 일정을 예약 할 수 있습니다.

system.scheduler.scheduler(offset, delay) { 
    checkFinishBidding() 
} 

checkFinishBidding() = { 
    registry.refFor[Entity](id).ask(SomeCommand) 
} 

그래서 시간 화재, 당신은 레지스트리에서 엔티티 심판 큐에서 단지 정상과 같은 명령을 실행할 수 있습니다

이 질문의 CQRS 부분에 대답하기 위해, 샘플 코드 같은 무언가를 서비스 호출.