|
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.