raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

re #281: Made akka-core compile and test after breaking changes introduced by removing the type parameter from ActorRef.!!.

Browse source
This commit is contained in:
Heiko Seeberger 2010-06-21 12:25:24 +02:00
parent 0e70a5face
commit 88125a9bc2
10 changed files with 24 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-core/src/main/scala/remote/RemoteServer.scala
View file

@ -10,8 +10,8 @@ import java.util.concurrent.{ConcurrentHashMap, Executors}
import java.util.{Map => JMap}
import se.scalablesolutions.akka.actor._
import se.scalablesolutions.akka.actor.Actor._
import se.scalablesolutions.akka.util._
import se.scalablesolutions.akka.util.Helpers.narrow
import se.scalablesolutions.akka.remote.protocol.RemoteProtocol._
import se.scalablesolutions.akka.config.Config.config
@ -370,7 +370,7 @@ class RemoteServerHandler(
if (request.getIsOneWay) actorRef.!(message)(sender)
else {
try {
val resultOrNone = narrow[AnyRef](actorRef.!!(message)(sender))
val resultOrNone = (actorRef.!!(message)(sender)).as[AnyRef]
val result = if (resultOrNone.isDefined) resultOrNone.get else null
log.debug("Returning result from actor invocation [%s]", result)
val replyBuilder = RemoteReplyProtocol.newBuilder