Hi,
I have two ActorSystems Node-A and Node-B in separate JVM processes with
netty-tcp remoting enabled running on the same machine (127.0.0.1) on port
2552 and 2553.
Each ActorSystem starts itself a actor.
The actor sends a "ping" message and replies to a sender with a "pong"
message using actorSelection which identifies the corresponding remote
actor.
On receiving a "ping" or "pong" message the sender actor is going to be
watched.
Everything works fine so far.
Then I kill the JVM process which was running ActorSystem Node-B.
Node-A detects the termination and after a while the remote system Node-B
becomes quarantined.
Now I restart the JVM process to launch the ActorSystem Node-B.
The ActorSystem Node-A notifies that Node-B is associated.
In the same instant ActorSystem Node-A terminates without any log message
or exception.
Node-B continues and notifies about that termination
This unexpected behaviour is reproducible.
Are there any known issues when quarantined ActorSystems are restarted?
Akka Version used: 2.3.9
Tested with: JRE 7 and 8
OS: Windows 7 x64
Stacktrace of thread which stops the ActorSystem due to receival of message
DeathWatchNotification(Actor[akka://Node-A/user],true,false):
"Node-A-akka.actor.default-dispatcher-14@2655" prio=5 tid=0x19 nid=NA
runnable
java.lang.Thread.State: RUNNABLE
at
akka.actor.LocalActorRefProvider$$anon$2.stop(ActorRefProvider.scala:491)
at
akka.actor.LocalActorRefProvider$$anon$2$$anonfun$sendSystemMessage$1.apply$mcV$sp(ActorRefProvider.scala:506)
at akka.util.Switch.ifOff(LockUtil.scala:85)
at
akka.actor.LocalActorRefProvider$$anon$2.sendSystemMessage(ActorRefProvider.scala:499)
at
akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(FaultHandling.scala:213)
at
akka.actor.dungeon.FaultHandling$class.handleChildTerminated(FaultHandling.scala:292)
at akka.actor.ActorCell.handleChildTerminated(ActorCell.scala:369)
at
akka.actor.dungeon.DeathWatch$class.watchedActorTerminated(DeathWatch.scala:63)
at akka.actor.ActorCell.watchedActorTerminated(ActorCell.scala:369)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:455)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
at akka.dispatch.Mailbox.run(Mailbox.scala:220)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at
scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
--
>>>>>>>>>> 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.
