var state: Option[Todo] = None
private var eventCounter = 0L
override def persistenceId: String = TodoAggregate.name(id)
override def receiveCommand: Receive = {
case Create(requestId, aggregateId, todoGroupId, text) =>
require(aggregateId == id)
val now = ZonedDateTime.now()
state = Some(Todo(id, todoGroupId, text, now, now))
persist(Created(UUID.randomUUID(), aggregateId,
todoGroupId, text, now, now)
) { event =>
sender() ! CreateSuccess(UUID.randomUUID(), requestId,
aggregateId, todoGroupId, text, now, now)
subscriber.foreach(_ ! event)
saveSnapshotEntity()
}
case Update(requestId, aggregateId, text) =>
require(aggregateId == id)
val now = ZonedDateTime.now()
state.map(_.copy(text = text, updateAt = now))
persist(Updated(UUID.randomUUID(),
aggregateId, text, now)
) { event =>
sender() ! UpdateSuccess(UUID.randomUUID(),
requestId, aggregateId, text, now)
subscriber.foreach(_ ! event)
saveSnapshotEntity()
} ɹঢ়ଶΛ࣋ͭ ӬଓԽ*% ίϚϯυϋϯυϥ ΠϕϯτΛӬଓԽ͢Δ ඞཁʹԠͯ͡ εφοϓγϣοτ Λ࡞ TFOEFS ʹ ϨεϙϯεΛฦ͢ 4VCTDSJCFSʹ υϝΠϯΠϕϯτΛ ௨
j5ik2o
imai448
nikinusu
chanyou0311
ewolff
gumamon
isaoshimizu
oracle4engineer
shujisado
lycorp_recruit_jp
10xinc
emiki
scottboms
maggiecrowley
rmw
swwweet
skipperchong
tammyeverts
philnash
aarron
pedronauck
hannesfritz
iamctodd
![4VQFSWJTPSܦ༝Ͱ࣮ߦ͢Δ implicit val system = ActorSystem() val childProps = Props[ToIntActor]](https://files.speakerdeck.com/presentations/16eabfa416394f28b9b5ff29b94771d3/slide_55.jpg){kind=link}
![[INFO][akka://default/user/$a/child] child start // 1ճޭɻ value = 1, result](https://files.speakerdeck.com/presentations/16eabfa416394f28b9b5ff29b94771d3/slide_56.jpg){kind=link}
![ूΞΫλʔ class TodoAggregate(id: TodoId, subscriber: Option[ActorRef]) extends PersistentActor { private](https://files.speakerdeck.com/presentations/16eabfa416394f28b9b5ff29b94771d3/slide_62.jpg){kind=link}
