Removing the intermediate InvocationTargetException and harmonizing creation of Actor instances

akka-actor/src/main/scala/akka/AkkaException.scala

@@ -19,11 +19,8 @@ import java.net.{InetAddress, UnknownHostException}
 class AkkaException(message: String = "", cause: Throwable = null) extends RuntimeException(message, cause) with Serializable {
   val uuid = "%s_%s".format(AkkaException.hostname, newUuid)
 
-  override lazy val toString = {
+  override lazy val toString =
-    val name = getClass.getName
+    "%s: %s\n[%s]\n%s".format(getClass.getName, message, uuid, stackTraceToString)
-    val trace = stackTraceToString
-    "%s: %s\n[%s]\n%s".format(name, message, uuid, trace)
-  }
 
   def stackTraceToString = {
     val trace = getStackTrace

akka-actor/src/main/scala/akka/actor/Actor.scala

@@ -14,6 +14,7 @@ import scala.reflect.BeanProperty
 import akka.util. {ReflectiveAccess, Duration}
 import akka.remoteinterface.RemoteSupport
 import akka.japi. {Creator, Procedure}
+import java.lang.reflect.InvocationTargetException
 
 /**
  * Life-cycle messages for the Actors
@@ -162,12 +163,18 @@ object Actor extends ListenerManagement {
   def actorOf(clazz: Class[_ <: Actor]): ActorRef = new LocalActorRef(() => {
     import ReflectiveAccess.{ createInstance, noParams, noArgs }
     createInstance[Actor](clazz.asInstanceOf[Class[_]], noParams, noArgs) match {
-      case r: Right[Exception, Actor] => r.b
+      case Right(actor) => actor
-      case l: Left[Exception, Actor] => throw new ActorInitializationException(
+      case Left(exception) =>
+        val cause = exception match {
+          case i: InvocationTargetException => i.getTargetException
+          case _ => exception
+        }
+
+        throw new ActorInitializationException(
           "Could not instantiate Actor of " + clazz +
           "\nMake sure Actor is NOT defined inside a class/trait," +
           "\nif so put it outside the class/trait, f.e. in a companion object," +
-        "\nOR try to change: 'actorOf[MyActor]' to 'actorOf(new MyActor)'.", l.a)
+          "\nOR try to change: 'actorOf[MyActor]' to 'actorOf(new MyActor)'.", cause)
     }
 
   }, None)

akka-actor/src/main/scala/akka/remoteinterface/RemoteInterface.scala

@@ -15,6 +15,7 @@ import scala.reflect.BeanProperty
 import java.net.InetSocketAddress
 import java.util.concurrent.ConcurrentHashMap
 import java.io.{PrintWriter, PrintStream}
+import java.lang.reflect.InvocationTargetException
 
 trait RemoteModule {
   val UUID_PREFIX = "uuid:".intern
@@ -186,18 +187,8 @@ abstract class RemoteSupport extends ListenerManagement with RemoteServerModule
    * </pre>
    */
   @deprecated("Will be removed after 1.1")
-  def actorOf(clazz: Class[_ <: Actor], host: String, port: Int): ActorRef = {
+  def actorOf(clazz: Class[_ <: Actor], host: String, port: Int): ActorRef =
-    import ReflectiveAccess.{ createInstance, noParams, noArgs }
+    clientManagedActorOf(() => createActorFromClass(clazz), host, port)
-    clientManagedActorOf(() =>
-        createInstance[Actor](clazz.asInstanceOf[Class[_]], noParams, noArgs) match {
-            case r: Right[_, Actor] => r.b
-            case l: Left[Exception, _] => throw new ActorInitializationException(
-              "Could not instantiate Actor" +
-              "\nMake sure Actor is NOT defined inside a class/trait," +
-              "\nif so put it outside the class/trait, f.e. in a companion object," +
-              "\nOR try to change: 'actorOf[MyActor]' to 'actorOf(new MyActor)'.", l.a)
-          }, host, port)
-  }
 
   /**
    * Creates a Client-managed ActorRef out of the Actor of the specified Class.
@@ -215,17 +206,26 @@ abstract class RemoteSupport extends ListenerManagement with RemoteServerModule
    * </pre>
    */
   @deprecated("Will be removed after 1.1")
-  def actorOf[T <: Actor : Manifest](host: String, port: Int): ActorRef = {
+  def actorOf[T <: Actor : Manifest](host: String, port: Int): ActorRef =
+    clientManagedActorOf(() => createActorFromClass(manifest.erasure), host, port)
+
+
+  protected def createActorFromClass(clazz: Class[_]): Actor = {
     import ReflectiveAccess.{ createInstance, noParams, noArgs }
-    clientManagedActorOf(() =>
+    createInstance[Actor](clazz, noParams, noArgs) match {
-      createInstance[Actor](manifest[T].erasure.asInstanceOf[Class[_]], noParams, noArgs) match {
+      case Right(actor) => actor
-          case r: Right[_, Actor] => r.b
+      case Left(exception) =>
-          case l: Left[Exception, _] => throw new ActorInitializationException(
+        val cause = exception match {
-            "Could not instantiate Actor" +
+          case i: InvocationTargetException => i.getTargetException
+          case _ => exception
+        }
+
+        throw new ActorInitializationException(
+          "Could not instantiate Actor of " + clazz +
           "\nMake sure Actor is NOT defined inside a class/trait," +
           "\nif so put it outside the class/trait, f.e. in a companion object," +
-            "\nOR try to change: 'actorOf[MyActor]' to 'actorOf(new MyActor)'.", l.a)
+          "\nOR try to change: 'actorOf[MyActor]' to 'actorOf(new MyActor)'.", cause)
-        }, host, port)
+    }
   }
 
   protected override def manageLifeCycleOfListeners = false