From efbc0a781f9df5b8017b75583a2319a7d6f41af1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Fri, 19 Apr 2013 13:36:39 +0200 Subject: [PATCH] Quarantine is in wrong block --- .../src/main/scala/akka/remote/Remoting.scala | 27 ++++++++++--------- 1 file changed, 14 insertions(+), 13 deletions(-) diff --git a/akka-remote/src/main/scala/akka/remote/Remoting.scala b/akka-remote/src/main/scala/akka/remote/Remoting.scala index 0e34c93e0f..7da7256c00 100644 --- a/akka-remote/src/main/scala/akka/remote/Remoting.scala +++ b/akka-remote/src/main/scala/akka/remote/Remoting.scala @@ -438,6 +438,20 @@ private[remote] class EndpointManager(conf: Config, log: LoggingAdapter) extends addressesPromise.success(transportsAndAddresses) case ManagementCommand(_) ⇒ sender ! ManagementCommandAck(false) + case StartupFinished ⇒ + context.become(accepting) + case ShutdownAndFlush ⇒ + sender ! true + context.stop(self) // Nothing to flush at this point + } + + val accepting: Receive = { + case ManagementCommand(cmd) ⇒ + val allStatuses = transportMapping.values map { transport ⇒ + transport.managementCommand(cmd) + } + Future.fold(allStatuses)(true)(_ && _) map ManagementCommandAck pipeTo sender + case Quarantine(address, uid) ⇒ settings.QuarantineDuration match { case d: FiniteDuration ⇒ @@ -454,19 +468,6 @@ private[remote] class EndpointManager(conf: Config, log: LoggingAdapter) extends endpoints.markAsQuarantined(address, uid, Deadline.now + d) case _ ⇒ // Ignore } - case StartupFinished ⇒ - context.become(accepting) - case ShutdownAndFlush ⇒ - sender ! true - context.stop(self) // Nothing to flush at this point - } - - val accepting: Receive = { - case ManagementCommand(cmd) ⇒ - val allStatuses = transportMapping.values map { transport ⇒ - transport.managementCommand(cmd) - } - Future.fold(allStatuses)(true)(_ && _) map ManagementCommandAck pipeTo sender case s @ Send(message, senderOption, recipientRef, _) ⇒ val recipientAddress = recipientRef.path.address