From f70bf9e89cbb00baccb11eee5195c751c141f64b Mon Sep 17 00:00:00 2001
From: Viktor Klang <viktor.klang@gmail.com>
Date: Wed, 3 Aug 2011 15:01:46 +0200
Subject: [PATCH] Adding Props to akka.actor package

---
 .../src/main/scala/akka/actor/ActorRef.scala  | 107 +++++++++++++++++-
 1 file changed, 106 insertions(+), 1 deletion(-)

diff --git a/akka-actor/src/main/scala/akka/actor/ActorRef.scala b/akka-actor/src/main/scala/akka/actor/ActorRef.scala
index 3af5853eec..80be55d047 100644
--- a/akka-actor/src/main/scala/akka/actor/ActorRef.scala
+++ b/akka-actor/src/main/scala/akka/actor/ActorRef.scala
@@ -20,7 +20,8 @@ import java.util.{ Map ⇒ JMap }
 import scala.reflect.BeanProperty
 import scala.collection.immutable.Stack
 import scala.annotation.tailrec
-import java.lang.IllegalStateException
+import java.lang.{ UnsupportedOperationException, IllegalStateException }
+import akka.japi.Creator
 
 private[akka] object ActorRefInternals {
 
@@ -39,6 +40,110 @@ private[akka] object ActorRefInternals {
 
 }
 
+/**
+ * ActorRef configuration object, this is threadsafe and fully sharable
+ *
+ * Props() returns default configuration
+ * TODO document me
+ */
+object Props {
+  val defaultTimeout: Timeout = Timeout(Duration(Actor.TIMEOUT, "millis"))
+  def defaultDispatcher: MessageDispatcher = Dispatchers.defaultGlobalDispatcher
+  val noCreatorSpecified: () ⇒ Actor = () ⇒ throw new UnsupportedOperationException("No actorFactoryProvided!")
+
+  val default = new Props(creator = noCreatorSpecified)
+  def apply(): Props = default
+
+  def apply[T <: Actor: Manifest]: Props =
+    default.withCreator(() ⇒ implicitly[Manifest[T]].erasure.asInstanceOf[Class[_ <: Actor]].newInstance)
+
+  def apply(actorClass: Class[_ <: Actor]): Props =
+    default.withCreator(() ⇒ actorClass.newInstance)
+}
+
+/**
+ * ActorRef configuration object, this is thread safe and fully sharable
+ */
+case class Props(creator: () ⇒ Actor,
+                 dispatcher: MessageDispatcher = Props.defaultDispatcher,
+                 timeout: Timeout = Props.defaultTimeout,
+                 receiveTimeout: Option[Duration] = None,
+                 lifeCycle: LifeCycle = Permanent,
+                 faultHandler: FaultHandlingStrategy = NoFaultHandlingStrategy,
+                 supervisor: Option[ActorRef] = None) {
+  /**
+   * Returns a new Props with the specified creator set
+   *  Scala API
+   */
+  def withCreator(c: () ⇒ Actor) = copy(creator = c)
+
+  /**
+   * Returns a new Props with the specified creator set
+   *  Java API
+   */
+  def withCreator(c: Creator[Actor]) = copy(creator = () ⇒ c.create)
+
+  /**
+   * Returns a new Props with the specified dispatcher set
+   *  Java API
+   */
+  def withDispatcher(d: MessageDispatcher) = copy(dispatcher = d)
+
+  /**
+   * Returns a new Props with the specified timeout set
+   * Java API
+   */
+  def withTimeout(t: Timeout) = copy(timeout = t)
+
+  /**
+   * Returns a new Props with the specified lifecycle set
+   * Java API
+   */
+  def withLifeCycle(l: LifeCycle) = copy(lifeCycle = l)
+
+  /**
+   * Returns a new Props with the specified faulthandler set
+   * Java API
+   */
+  def withFaultHandler(f: FaultHandlingStrategy) = copy(faultHandler = f)
+
+  /**
+   * Returns a new Props with the specified supervisor set, if null, it's equivalent to withSupervisor(Option.none())
+   * Java API
+   */
+  def withSupervisor(s: ActorRef) = copy(supervisor = Option(s))
+
+  /**
+   * Returns a new Props with the specified supervisor set
+   * Java API
+   */
+  def withSupervisor(s: akka.japi.Option[ActorRef]) = copy(supervisor = s.asScala)
+
+  /**
+   * Returns a new Props with the specified supervisor set
+   * Scala API
+   */
+  def withSupervisor(s: scala.Option[ActorRef]) = copy(supervisor = s)
+
+  /**
+   * Returns a new Props with the specified receive timeout set, if null, it's equivalent to withReceiveTimeout(Option.none())
+   * Java API
+   */
+  def withReceiveTimeout(r: Duration) = copy(receiveTimeout = Option(r))
+
+  /**
+   * Returns a new Props with the specified receive timeout set
+   * Java API
+   */
+  def withReceiveTimeout(r: akka.japi.Option[Duration]) = copy(receiveTimeout = r.asScala)
+
+  /**
+   * Returns a new Props with the specified receive timeout set
+   * Scala API
+   */
+  def withReceiveTimeout(r: scala.Option[Duration]) = copy(receiveTimeout = r)
+}
+
 /**
  * ActorRef is an immutable and serializable handle to an Actor.
  * <p/>