|
Akka/Scala example source code file (RemoteDeploymentDocSpec.scala)
The RemoteDeploymentDocSpec.scala Akka example source code
/**
* Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com>
*/
package docs.remoting
import akka.actor.{ ExtendedActorSystem, ActorSystem, Actor, ActorRef }
import akka.testkit.{ AkkaSpec, ImplicitSender }
//#import
import akka.actor.{ Props, Deploy, Address, AddressFromURIString }
import akka.remote.RemoteScope
//#import
object RemoteDeploymentDocSpec {
class SampleActor extends Actor {
def receive = { case _ => sender() ! self }
}
}
class RemoteDeploymentDocSpec extends AkkaSpec("""
akka.actor.provider = "akka.remote.RemoteActorRefProvider"
akka.remote.netty.tcp {
port = 0
}
""") with ImplicitSender {
import RemoteDeploymentDocSpec._
val other = ActorSystem("remote", system.settings.config)
val address = other.asInstanceOf[ExtendedActorSystem].provider.getExternalAddressFor(Address("akka.tcp", "s", "host", 1)).get
override def afterTermination() { shutdown(other) }
"demonstrate programmatic deployment" in {
//#deploy
val ref = system.actorOf(Props[SampleActor].
withDeploy(Deploy(scope = RemoteScope(address))))
//#deploy
ref.path.address should be(address)
ref ! "test"
expectMsgType[ActorRef].path.address should be(address)
}
"demonstrate address extractor" in {
//#make-address
val one = AddressFromURIString("akka.tcp://sys@host:1234")
val two = Address("akka.tcp", "sys", "host", 1234) // this gives the same
//#make-address
one should be(two)
}
"demonstrate sampleActor" in {
//#sample-actor
val actor = system.actorOf(Props[SampleActor], "sampleActor")
actor ! "Pretty slick"
//#sample-actor
}
}
Other Akka source code examplesHere is a short list of links related to this Akka RemoteDeploymentDocSpec.scala source code file: |
| ... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2024 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.