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

merged in akka-sample-remote

Browse source
This commit is contained in:
Jonas Bonér 2010-05-04 10:45:01 +02:00
parent 413c37dfec
commit e8513c2b8c
2 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-samples/akka-sample-remote/src/main/scala/ClientManagedRemoteActorSample.scala
View file

@ -4,6 +4,7 @@
package sample.remote
import se.scalablesolutions.akka.actor.Actor._
import se.scalablesolutions.akka.actor.RemoteActor
import se.scalablesolutions.akka.remote.RemoteNode
import se.scalablesolutions.akka.util.Logging
@ -30,7 +31,7 @@ object ClientManagedRemoteActorServer extends Logging {
object ClientManagedRemoteActorClient extends Logging {
def run = {
val actor = new RemoteHelloWorldActor
val actor = newActor[RemoteHelloWorldActor]
log.info("Remote actor created, moved to the server")
log.info("Sending 'Hello' to remote actor")
val result = actor !! "Hello"

3
akka-samples/akka-sample-remote/src/main/scala/ServerManagedRemoteActorSample.scala
View file

@ -5,6 +5,7 @@
package sample.remote
import se.scalablesolutions.akka.actor.Actor
import se.scalablesolutions.akka.actor.Actor._
import se.scalablesolutions.akka.remote.{RemoteClient, RemoteNode}
import se.scalablesolutions.akka.util.Logging
@ -22,7 +23,7 @@ object ServerManagedRemoteActorServer extends Logging {
def run = {
RemoteNode.start("localhost", 9999)
log.info("Remote node started")
RemoteNode.register("hello-service", new HelloWorldActor)
RemoteNode.register("hello-service", newActor[HelloWorldActor])
log.info("Remote actor registered and started")
}