From a6c4bfa98c092ec57cd3c247d38668f8a7b65f2f Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Mon, 31 Oct 2011 22:18:21 +0100 Subject: [PATCH] #1324 - making sure that ActorPools are prefilled --- akka-actor/src/main/scala/akka/routing/Pool.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/akka-actor/src/main/scala/akka/routing/Pool.scala b/akka-actor/src/main/scala/akka/routing/Pool.scala index 8a26c25a84..dbf71bad04 100644 --- a/akka-actor/src/main/scala/akka/routing/Pool.scala +++ b/akka-actor/src/main/scala/akka/routing/Pool.scala @@ -95,6 +95,10 @@ trait DefaultActorPool extends ActorPool { this: Actor ⇒ val defaultProps: Props = Props.default.withDispatcher(this.context.dispatcher) + override def preStart() { + resizeIfAppropriate() + } + override def postStop() { _delegates foreach evict _delegates = Vector.empty @@ -112,7 +116,7 @@ trait DefaultActorPool extends ActorPool { this: Actor ⇒ select(_delegates) foreach { _ forward msg } } - private def resizeIfAppropriate() { + protected def resizeIfAppropriate() { val requestedCapacity = capacity(_delegates) val newDelegates = requestedCapacity match { case qty if qty > 0 ⇒