raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=rem #3527 Correction of match in reWatch

Browse source
This commit is contained in:
Patrik Nordwall 2013-08-26 11:59:19 +02:00
parent cdea2af973
commit 12a442f7d0
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-remote/src/main/scala/akka/remote/RemoteWatcher.scala
View file

@ -276,9 +276,11 @@ private[akka] class RemoteWatcher(
*/
def reWatch(address: Address): Unit =
watching.foreach {
case (wee: InternalActorRef, wer: InternalActorRef) if wee.path.address == address ⇒
log.debug("Re-watch [{} -> {}]", wer, wee)
wee.sendSystemMessage(Watch(wee, wer)) // ➡➡➡ NEVER SEND THE SAME SYSTEM MESSAGE OBJECT TO TWO ACTORS ⬅⬅⬅
case (wee: InternalActorRef, wer: InternalActorRef) ⇒
if (wee.path.address == address) {
log.debug("Re-watch [{} -> {}]", wer, wee)
wee.sendSystemMessage(Watch(wee, wer)) // ➡➡➡ NEVER SEND THE SAME SYSTEM MESSAGE OBJECT TO TWO ACTORS ⬅⬅⬅
}
}
}