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

shortname for provider config

Browse source
This commit is contained in:
Patrik Nordwall 2016-09-29 15:01:05 +02:00
parent deb26d212f
commit 8d36499cd4
7 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-tools/src/multi-jvm/scala/akka/cluster/pubsub/DistributedPubSubRestartSpec.scala
View file

@ -36,7 +36,7 @@ object DistributedPubSubRestartSpec extends MultiNodeConfig {
commonConfig(ConfigFactory.parseString("""
akka.loglevel = INFO
akka.cluster.pub-sub.gossip-interval = 500ms
akka.actor.provider = "akka.cluster.ClusterActorRefProvider"
akka.actor.provider = cluster
akka.remote.log-remote-lifecycle-events = off
akka.cluster.auto-down-unreachable-after = off
"""))

2
akka-http-tests/src/multi-jvm/scala/akka/http/AkkaHttpServerLatencyMultiNodeSpec.scala
View file

@ -32,7 +32,7 @@ object AkkaHttpServerLatencyMultiNodeSpec extends MultiNodeConfig {
"""
akka {
actor.default-mailbox.mailbox-type = "akka.dispatch.UnboundedMailbox"
actor.provider = "akka.remote.RemoteActorRefProvider"
actor.provider = remote
stream.materializer.debug.fuzzing-mode = off
testconductor.barrier-timeout = 30m

2
akka-remote/src/test/scala/akka/remote/artery/compress/HandshakeShouldDropCompressionTableSpec.scala
View file

@ -26,7 +26,7 @@ object HandshakeShouldDropCompressionTableSpec {
akka {
loglevel = INFO
actor.provider = "akka.remote.RemoteActorRefProvider"
actor.provider = remote
remote.artery.enabled = on
remote.artery.canonical.hostname = localhost
remote.artery.canonical.port = 0

2
akka-samples/akka-sample-cluster-scala/src/main/resources/application.conf
View file

@ -1,7 +1,7 @@
#//#snippet
akka {
actor {
provider = "akka.cluster.ClusterActorRefProvider"
provider = cluster
}
remote {
log-remote-lifecycle-events = off

2
akka-samples/akka-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala
View file

@ -40,7 +40,7 @@ object StatsSampleSpecConfig extends MultiNodeConfig {
// this configuration will be used for all nodes
// note that no fixed host names and ports are used
commonConfig(ConfigFactory.parseString("""
akka.actor.provider = "akka.cluster.ClusterActorRefProvider"
akka.actor.provider = cluster
akka.remote.log-remote-lifecycle-events = off
akka.cluster.roles = [compute]
#//#router-lookup-config

2
akka-samples/akka-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/transformation/TransformationSampleSpec.scala
View file

@ -42,7 +42,7 @@ object TransformationSampleSpecConfig extends MultiNodeConfig {
// this configuration will be used for all nodes
// note that no fixed host names and ports are used
commonConfig(ConfigFactory.parseString("""
akka.actor.provider = "akka.cluster.ClusterActorRefProvider"
akka.actor.provider = cluster
akka.remote.log-remote-lifecycle-events = off
"""))

2
project/AkkaBuild.scala
View file

@ -528,7 +528,7 @@ object AkkaBuild extends Build {
|import scala.concurrent.duration._
|import akka.util.Timeout
|var config = ConfigFactory.parseString("akka.stdout-loglevel=INFO,akka.loglevel=DEBUG,pinned{type=PinnedDispatcher,executor=thread-pool-executor,throughput=1000}")
|var remoteConfig = ConfigFactory.parseString("akka.remote.netty{port=0,use-dispatcher-for-io=akka.actor.default-dispatcher,execution-pool-size=0},akka.actor.provider=akka.remote.RemoteActorRefProvider").withFallback(config)
|var remoteConfig = ConfigFactory.parseString("akka.remote.netty{port=0,use-dispatcher-for-io=akka.actor.default-dispatcher,execution-pool-size=0},akka.actor.provider=remote").withFallback(config)
|var system: ActorSystem = null
|implicit def _system = system
|def startSystem(remoting: Boolean = false) { system = ActorSystem("repl", if(remoting) remoteConfig else config); println("don’t forget to system.terminate()!") }