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

Renaming NettyRemoteSupport to NettyRemoteTransport everywhere

Browse source
This commit is contained in:
Viktor Klang 2012-02-01 16:34:20 +01:00
parent e58d0d9940
commit d0d391b1dc
6 changed files with 12 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-docs/java/remoting.rst
View file

@ -25,7 +25,7 @@ to your ``application.conf`` file::
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
transport = "akka.remote.netty.NettyRemoteSupport"
transport = "akka.remote.netty.NettyRemoteTransport"
server {
hostname = "127.0.0.1"
port = 2552

2
akka-docs/scala/remoting.rst
View file

@ -21,7 +21,7 @@ to your ``application.conf`` file::
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
transport = "akka.remote.netty.NettyRemoteSupport"
transport = "akka.remote.netty.NettyRemoteTransport"
server {
hostname = "127.0.0.1"
port = 2552

2
akka-samples/akka-sample-remote/src/main/resources/common.conf
View file

@ -6,7 +6,7 @@ akka {
}
remote {
transport = "akka.remote.netty.NettyRemoteSupport"
transport = "akka.remote.netty.NettyRemoteTransport"
server {
hostname = "127.0.0.1"
}

2
akka-spring/src/test/resources/akka-test.conf
View file

@ -128,7 +128,7 @@ akka {
# secure-cookie = "050E0A0D0D06010A00000900040D060F0C09060B" # generate your own with '$AKKA_HOME/scripts/generate_secure_cookie.sh' or using 'Crypt.generateSecureCookie'
secure-cookie = ""
layer = "akka.remote.netty.NettyRemoteSupport"
layer = "akka.remote.netty.NettyRemoteTransport"
server {
hostname = "localhost" # The hostname or IP that clients should connect to

8
akka-spring/src/test/scala/TypedActorSpringFeatureTest.scala
View file

@ -13,7 +13,7 @@ import org.springframework.context.ApplicationContext
import org.springframework.context.support.ClassPathXmlApplicationContext
import org.springframework.core.io.{ ClassPathResource, Resource }
import org.scalatest.{ BeforeAndAfterAll, FeatureSpec }
import akka.remote.netty.NettyRemoteSupport
import akka.remote.netty.NettyRemoteTransport
import akka.actor._
import akka.actor.Actor._
import java.util.concurrent.{TimeoutException, CountDownLatch}
@ -36,17 +36,17 @@ object RemoteTypedActorLog {
@RunWith(classOf[JUnitRunner])
class TypedActorSpringFeatureTest extends FeatureSpec with ShouldMatchers with BeforeAndAfterAll {
var optimizeLocal_? = remote.asInstanceOf[NettyRemoteSupport].optimizeLocalScoped_?
var optimizeLocal_? = remote.asInstanceOf[NettyRemoteTransport].optimizeLocalScoped_?
override def beforeAll {
remote.asInstanceOf[NettyRemoteSupport].optimizeLocal.set(false) //Can't run the test if we're eliminating all remote calls
remote.asInstanceOf[NettyRemoteTransport].optimizeLocal.set(false) //Can't run the test if we're eliminating all remote calls
remote.start("localhost", 9990)
val typedActor = TypedActor.newInstance(classOf[RemoteTypedActorOne], classOf[RemoteTypedActorOneImpl], 1000)
remote.registerTypedActor("typed-actor-service", typedActor)
}
override def afterAll {
remote.asInstanceOf[NettyRemoteSupport].optimizeLocal.set(optimizeLocal_?) //Reset optimizelocal after all tests
remote.asInstanceOf[NettyRemoteTransport].optimizeLocal.set(optimizeLocal_?) //Reset optimizelocal after all tests
remote.shutdown
Thread.sleep(1000)

8
akka-spring/src/test/scala/UntypedActorSpringFeatureTest.scala
View file

@ -9,7 +9,7 @@ import org.scalatest.matchers.ShouldMatchers
import org.scalatest.junit.JUnitRunner
import org.junit.runner.RunWith
import org.springframework.context.support.ClassPathXmlApplicationContext
import akka.remote.netty.NettyRemoteSupport
import akka.remote.netty.NettyRemoteTransport
import org.scalatest.{ BeforeAndAfterAll, FeatureSpec }
import java.util.concurrent.CountDownLatch
@ -23,15 +23,15 @@ import akka.actor.Actor._
@RunWith(classOf[JUnitRunner])
class UntypedActorSpringFeatureTest extends FeatureSpec with ShouldMatchers with BeforeAndAfterAll {
var optimizeLocal_? = remote.asInstanceOf[NettyRemoteSupport].optimizeLocalScoped_?
var optimizeLocal_? = remote.asInstanceOf[NettyRemoteTransport].optimizeLocalScoped_?
override def beforeAll {
remote.asInstanceOf[NettyRemoteSupport].optimizeLocal.set(false) //Can't run the test if we're eliminating all remote calls
remote.asInstanceOf[NettyRemoteTransport].optimizeLocal.set(false) //Can't run the test if we're eliminating all remote calls
remote.start("localhost", 9990)
}
override def afterAll {
remote.asInstanceOf[NettyRemoteSupport].optimizeLocal.set(optimizeLocal_?) //Reset optimizelocal after all tests
remote.asInstanceOf[NettyRemoteTransport].optimizeLocal.set(optimizeLocal_?) //Reset optimizelocal after all tests
remote.shutdown
Thread.sleep(1000)