Hi Nader,
You'll get the full benefit of PersistentFSM if you use event sourcing and
use the PersistentFSM actor to persist your business events.
In PersistentFSM you can persist domain events as part of a state change.
This way either both state change and your event are persisted successfully
or they both fail:
abstract class TransactionIssueSolved extends PersistentFSM[State, Any, Any] {
startWith(InProcess, EmptyIssueData)
when(InProcess) {
case Event(commit: Commit, _) =>
goto(Closed) applying Committed(commit.name)
}
initialize()
}
On Saturday, November 28, 2015 at 9:24:36 PM UTC+2, Nader Aeinehchi wrote:
>
> I am currently modeling a PersistentFSM actor and humbly ask for guidance.
>
> Suppose, we write a name to a database in the state "InProcess". Having
> successfully committed to the database, we would like the state machine to
> change its state to "Closed".
> What if we manage to write to the database, but the actor crashes before
> getting notified or before it manages to update its state?
>
> Please look at the following code:
>
> sealed abstract class State
> case object InProcess extends State
> case object Closed extends State
>
> case class Commit(val name:String)
> case class Committed(val name: String)
>
> class DatabaseActor extends Actor {
> def receive = {
> case Commit(name) =>
> //Write to database......
> //......
> sender ! Committed(name)
> case _ => //"received unknown message")
> }
> }
>
> //Sorry, I am using old API
> abstract class TransactionIssue extends PersistentFsmActor[State, Any,
> Any] with Actor {
>
> startWith(InProcess, EmptyIssueData)
>
> when(InProcess) {
> case Event(commit: Commit, _) =>
> val databaseActor = context.actorOf(Props[DatabaseActor],
> "DatabaseActor")
> databaseActor ! commit
> stay
> case Event(commit: Committed, _) =>
> goto(Closed)
> }
>
> initialize
> }
>
> In advance, thank you very much.
>
>
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
