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

Merge pull request #1354 from drewhk/wip-fix-outbound-quarantine-drewhk

Browse source 
Fixed bug in outbound quarantine
This commit is contained in:
drewhk 2013-04-19 06:59:13 -07:00
commit eeb92e1bfb
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-remote/src/main/scala/akka/remote/Remoting.scala
View file

@ -488,8 +488,8 @@ private[remote] class EndpointManager(conf: Config, log: LoggingAdapter) extends
if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(None) ! s if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(None) ! s
else extendedSystem.deadLetters ! s else extendedSystem.deadLetters ! s
case Some(Quarantined(uid, timeOfRelease)) ⇒ case Some(Quarantined(uid, timeOfRelease)) ⇒
if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(Some(uid)) ! s if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(None) ! s
else createAndRegisterWritingEndpoint(None) ! s else createAndRegisterWritingEndpoint(Some(uid)) ! s
case None ⇒ case None ⇒
createAndRegisterWritingEndpoint(None) ! s createAndRegisterWritingEndpoint(None) ! s