From 25c75f9e7e4b0591d6d54de4e774c99fe711ebb4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Fri, 19 Apr 2013 15:31:03 +0200 Subject: [PATCH] Fixed bug in outbound quarantine --- akka-remote/src/main/scala/akka/remote/Remoting.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-remote/src/main/scala/akka/remote/Remoting.scala b/akka-remote/src/main/scala/akka/remote/Remoting.scala index 7da7256c00..80192694ec 100644 --- a/akka-remote/src/main/scala/akka/remote/Remoting.scala +++ b/akka-remote/src/main/scala/akka/remote/Remoting.scala @@ -488,8 +488,8 @@ private[remote] class EndpointManager(conf: Config, log: LoggingAdapter) extends if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(None) ! s else extendedSystem.deadLetters ! s case Some(Quarantined(uid, timeOfRelease)) ⇒ - if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(Some(uid)) ! s - else createAndRegisterWritingEndpoint(None) ! s + if (timeOfRelease.isOverdue()) createAndRegisterWritingEndpoint(None) ! s + else createAndRegisterWritingEndpoint(Some(uid)) ! s case None ⇒ createAndRegisterWritingEndpoint(None) ! s