Akka 2.5.3
On Saturday, July 15, 2017 at 11:35:04 PM UTC+7, Hengky Sucanda wrote:
>
> Hi Guys, i am experiencing NPE when starting a persistent FSM that is
> cluster sharded:
>
> a.a.OneForOneStrategy - null
> java.lang.NullPointerException: null
> at
> akka.persistence.fsm.PersistentFSM$$anonfun$receiveRecover$1.applyOrElse(PersistentFSM.scala:121)
>
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at
> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
> ~[scala-library-2.11.9.jar:1.0.1]
> at
> co.styletheory.user.impl.process.registration.UserRegistrationProcess$$anonfun$receiveRecover$1.applyOrElse(UserRegistrationProcess.scala:60)
>
> ~[classes/:na]
> at
> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
> ~[scala-library-2.11.9.jar:1.0.1]
> at
> akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:452)
>
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at akka.actor.Actor$class.aroundReceive(Actor.scala:513)
> ~[akka-actor_2.11-2.5.3.jar:na]
> at
> co.styletheory.user.impl.process.registration.UserRegistrationProcess.akka$persistence$Eventsourced$$super$aroundReceive(UserRegistrationProcess.scala:10)
>
> ~[classes/:na]
> at
> akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:538)
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at
> akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:183)
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at
> co.styletheory.user.impl.process.registration.UserRegistrationProcess.aroundReceive(UserRegistrationProcess.scala:10)
>
> ~[classes/:na]
> [error] a.a.OneForOneStrategy - permits must not be negative
> java.lang.IllegalStateException: permits must not be negative
> at
> akka.persistence.RecoveryPermitter.akka$persistence$RecoveryPermitter$$returnRecoveryPermit(RecoveryPermitter.scala:63)
>
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at
> akka.persistence.RecoveryPermitter$$anonfun$receive$1.applyOrElse(RecoveryPermitter.scala:52)
>
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at akka.actor.Actor$class.aroundReceive(Actor.scala:513)
> ~[akka-actor_2.11-2.5.3.jar:na]
> at
> akka.persistence.RecoveryPermitter.aroundReceive(RecoveryPermitter.scala:32)
> ~[akka-persistence_2.11-2.5.3.jar:na]
> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:527)
> [akka-actor_2.11-2.5.3.jar:na]
> at akka.actor.ActorCell.invoke(ActorCell.scala:496)
> [akka-actor_2.11-2.5.3.jar:na]
> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
> [akka-actor_2.11-2.5.3.jar:na]
> at akka.dispatch.Mailbox.run(Mailbox.scala:224)
> [akka-actor_2.11-2.5.3.jar:na]
> at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
> [akka-actor_2.11-2.5.3.jar:na]
> at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> [akka-actor_2.11-2.5.3.jar:na]
>
>
> My FSM looks like this:
>
> class UserRegistrationProcess(implicit val domainEventClassTag:
> ClassTag[RegistrationEvent])
> extends PersistentFSM[RegistrationStatus, RegistrationForm,
> RegistrationEvent] {
>
> println("starting actor process")
>
> override def persistenceId = s"RegistrationProcess-${self.path.name}"
>
> override def applyEvent(domainEvent: RegistrationEvent, currentData:
> RegistrationForm): RegistrationForm = {
> domainEvent match {
> case RegistrationRequested(request) =>
> currentData.fillForm(request)
> case UserRegistered(email) => DuplicateRegistrationForm
> case UserRegistrationCompleted(email) => CompleteRegistrationForm
> case _ => currentData
> }
> }
>
> startWith(NotRegistered, EmptyRegistrationForm)
>
> when(NotRegistered) {
> case Event(InitiateRegistrationProcess(id, request), data) =>
> println("test 2")
> val senderRef = sender()
> goto(Registering) applying RegistrationRequested(request) andThen
> (data => senderRef ! data)
> case Event(_, data) =>
> println("test")
> stay replying data
> }
>
> when(Registering) {
> case Event(MarkUserRegisteredFromDuplicateForm(email), _) =>
> val senderRef = sender()
> goto(Registered) applying UserRegistered(email) andThen (data =>
> senderRef ! data)
> case Event(MarkRegistrationComplete(email), _) =>
> val senderRef = sender()
> goto(Registered) applying UserRegistrationCompleted(email) andThen
> (data => senderRef ! data)
> case Event(InitiateRegistrationProcess(id, request), data) =>
> stay() replying data
> }
>
> when(Registered) {
> case Event(InitiateRegistrationProcess(id, request), data) =>
> stay() replying DuplicateRegistrationForm
> case Event(_, data) =>
> stay replying data
> }
>
> override def receiveRecover: Receive = {
> case null =>
> case any =>
> println("recovering " + any.toString)
> super.receiveRecover(any)
> }
> }
>
>
> Been debugging from some time and can't figure out why it happens. Any
> help is appreciated.
>
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
