Fixed bug in setting sender ref + changed version to 0.10

akka-core/src/main/scala/actor/ActorRef.scala

@@ -891,7 +891,6 @@ sealed class LocalActorRef private[akka](
   }
 
   protected[akka] def postMessageToMailbox(message: Any, senderOption: Option[ActorRef]): Unit = {
-    sender = senderOption
     joinTransaction(message)
 
     if (remoteAddress.isDefined) {
@@ -924,7 +923,6 @@ sealed class LocalActorRef private[akka](
       timeout: Long,
       senderOption: Option[ActorRef],
       senderFuture: Option[CompletableFuture[T]]): CompletableFuture[T] = {
-    sender = senderOption
     joinTransaction(message)
 
     if (remoteAddress.isDefined) {
@@ -974,9 +972,9 @@ sealed class LocalActorRef private[akka](
       Actor.log.warning("Actor [%s] is shut down, ignoring message [%s]", toString, messageHandle)
       return
     }
+    sender = messageHandle.sender
+    senderFuture = messageHandle.senderFuture
     try {
-      sender = messageHandle.sender
-      senderFuture = messageHandle.senderFuture
       if (TransactionManagement.isTransactionalityEnabled) transactionalDispatch(messageHandle)
       else dispatch(messageHandle)
     } catch {
@@ -990,9 +988,7 @@ sealed class LocalActorRef private[akka](
     val message = messageHandle.message //serializeMessage(messageHandle.message)
     setTransactionSet(messageHandle.transactionSet)
     try {
-      if (actor.base.isDefinedAt(message)) actor.base(message) // invoke user actor's receive partial function
-      else throw new IllegalArgumentException(
-        "No handler matching message [" + message + "] in " + toString)
+      actor.base(message)
     } catch {
       case e =>
         _isBeingRestarted = true
@@ -1021,20 +1017,16 @@ sealed class LocalActorRef private[akka](
       }
     setTransactionSet(txSet)
 
-    def proceed = {
-      if (actor.base.isDefinedAt(message)) actor.base(message) // invoke user actor's receive partial function
-      else throw new IllegalArgumentException(
-        toString + " could not process message [" + message + "]" +
-        "\n\tsince no matching 'case' clause in its 'receive' method could be found")
-      setTransactionSet(txSet) // restore transaction set to allow atomic block to do commit
-    }
-
     try {
       if (isTransactor) {
         atomic {
-          proceed
+          actor.base(message)
+          setTransactionSet(txSet) // restore transaction set to allow atomic block to do commit
         }
-      } else proceed
+      } else {
+        actor.base(message)
+        setTransactionSet(txSet) // restore transaction set to allow atomic block to do commit
+      }
     } catch {
       case e: IllegalStateException => {}
       case e =>

akka-core/src/main/scala/config/Config.scala

@@ -16,7 +16,7 @@ class ConfigurationException(message: String) extends RuntimeException(message)
  * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
  */
 object Config extends Logging {
-  val VERSION = "0.10-SNAPSHOT"
+  val VERSION = "0.10"
 
   // Set Multiverse options for max speed
   System.setProperty("org.multiverse.MuliverseConstants.sanityChecks", "false")

config/akka-reference.conf

@@ -15,7 +15,7 @@
 </log>
 
 <akka>
-  version = "0.10-SNAPSHOT"
+  version = "0.10"
 
   # FQN (Fully Qualified Name) to the class doing initial active object/actor
   # supervisor bootstrap, should be defined in default constructor

project/build.properties

@@ -1,6 +1,6 @@
 project.organization=se.scalablesolutions.akka
 project.name=akka
-project.version=0.10-SNAPSHOT
+project.version=0.10
 scala.version=2.8.0.RC3
 sbt.version=0.7.4
 def.scala.version=2.7.7