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

Removed trailing whitespace

Browse source
This commit is contained in:
Jonas Bonér 2010-06-30 16:26:15 +02:00
parent 189671325d
commit 21dc177b88
42 changed files with 152 additions and 152 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -324,7 +324,7 @@ class RemoteServerHandler(
applicationLoader.foreach(MessageSerializer.setClassLoader(_))
/**
* ChannelOpen overridden to store open channels for a clean shutdown of a RemoteServer.
* ChannelOpen overridden to store open channels for a clean shutdown of a RemoteServer.
* If a channel is closed before, it is automatically removed from the open channels group.
*/
override def channelOpen(ctx: ChannelHandlerContext, event: ChannelStateEvent) {
@ -364,7 +364,7 @@ class RemoteServerHandler(
val actorRef = createActor(request.getTarget, request.getUuid, request.getTimeout)
actorRef.start
val message = MessageSerializer.deserialize(request.getMessage)
val sender =
val sender =
if (request.hasSender) Some(ActorRef.fromProtobufToRemoteActorRef(request.getSender, applicationLoader))
else None
if (request.getIsOneWay) actorRef.!(message)(sender)