diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/ClusterWatcherNoClusterWatcheeSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/ClusterWatcherNoClusterWatcheeSpec.scala index ede5e322a3..18dbf0b836 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/ClusterWatcherNoClusterWatcheeSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/ClusterWatcherNoClusterWatcheeSpec.scala @@ -29,7 +29,7 @@ class ClusterWatcherNoClusterWatcheeConfig(val useUnsafe: Boolean, artery: Boole val remoting = role("remoting") commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" - akka.remote.use-unsafe-remote-features-without-cluster = $useUnsafe + akka.remote.use-unsafe-remote-features-outside-cluster = $useUnsafe akka.remote.log-remote-lifecycle-events = off akka.remote.artery.enabled = $artery akka.remote.artery.advanced.flight-recorder.enabled = off diff --git a/akka-docs/src/main/paradox/project/migration-guide-2.5.x-2.6.x.md b/akka-docs/src/main/paradox/project/migration-guide-2.5.x-2.6.x.md index 61b2946fca..cc1c14faba 100644 --- a/akka-docs/src/main/paradox/project/migration-guide-2.5.x-2.6.x.md +++ b/akka-docs/src/main/paradox/project/migration-guide-2.5.x-2.6.x.md @@ -272,21 +272,29 @@ By default, these remoting features are disabled when not using Akka Cluster: * Remote Deployment: falls back to creating a local actor * Remote Watch: ignores the watch and unwatch request, and `Terminated` will not be delivered when the remote actor is stopped or if a remote node crashes + +Watching an actor on a node outside the cluster may have unexpected +@ref[consequences](../remoting-artery.md#quarantine), such as quarantining +so it has been disabled by default in Akka 2.6. This is the case if either +cluster is not used at all (only plain remoting) or when watching an actor outside of the cluster. -When used with Cluster, all previous behavior is the same except a remote watch of an actor is no longer possible before a node joins a cluster, only after. +On the other hand, failure detection between nodes of the same cluster +do not have that shortcoming. Thus, when remote watching or deployment is used within +the same cluster, they are working the same in 2.6 as before, except that a remote watch attempt before a node has joined +will log a warning and be ignored, it must be done after the node has joined. -To optionally enable them without Cluster, if you understand -the @ref[consequences](../remoting-artery.md#quarantine), set +To optionally enable a watch without Akka Cluster or across a Cluster boundary between Cluster and non Cluster, +knowing the consequences, all watchers (cluster as well as remote) need to set ``` -akka.remote.use-unsafe-remote-features-without-cluster = on`. +akka.remote.use-unsafe-remote-features-outside-cluster = on`. ``` -When used without Cluster +When enabled * An initial warning is logged on startup of `RemoteActorRefProvider` * A warning will be logged on remote watch attempts, which you can suppress by setting ``` -akka.remote.warn-unsafe-watch-without-cluster = off +akka.remote.warn-unsafe-watch-outside-cluster = off ``` ### Schedule periodically with fixed-delay vs. fixed-rate diff --git a/akka-docs/src/test/scala/docs/remoting/RemoteDeploymentDocSpec.scala b/akka-docs/src/test/scala/docs/remoting/RemoteDeploymentDocSpec.scala index f0375ae838..f59b18ecc4 100644 --- a/akka-docs/src/test/scala/docs/remoting/RemoteDeploymentDocSpec.scala +++ b/akka-docs/src/test/scala/docs/remoting/RemoteDeploymentDocSpec.scala @@ -23,7 +23,7 @@ class RemoteDeploymentDocSpec extends AkkaSpec(""" akka.actor.provider = remote akka.remote.classic.netty.tcp.port = 0 akka.remote.artery.canonical.port = 0 - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """) with ImplicitSender { import RemoteDeploymentDocSpec._ diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/AttemptSysMsgRedeliverySpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/AttemptSysMsgRedeliverySpec.scala index a6741e3b69..819632203c 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/AttemptSysMsgRedeliverySpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/AttemptSysMsgRedeliverySpec.scala @@ -24,7 +24,7 @@ class AttemptSysMsgRedeliveryMultiJvmSpec(artery: Boolean) extends MultiNodeConf commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)).withFallback(RemotingMultiNodeSpec.commonConfig)) testTransport(on = true) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/NewRemoteActorSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/NewRemoteActorSpec.scala index f750a9d546..dc2c7936cf 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/NewRemoteActorSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/NewRemoteActorSpec.scala @@ -21,7 +21,7 @@ class NewRemoteActorMultiJvmSpec(artery: Boolean) extends MultiNodeConfig { commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" akka.remote.log-remote-lifecycle-events = off akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """).withFallback(RemotingMultiNodeSpec.commonConfig))) val master = role("master") diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteDeploymentDeathWatchSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteDeploymentDeathWatchSpec.scala index 12ee88826c..5d7b484af3 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteDeploymentDeathWatchSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteDeploymentDeathWatchSpec.scala @@ -24,7 +24,7 @@ class RemoteDeploymentDeathWatchMultiJvmSpec(artery: Boolean) extends MultiNodeC akka.loglevel = INFO akka.remote.log-remote-lifecycle-events = off akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)).withFallback(RemotingMultiNodeSpec.commonConfig)) deployOn(second, """/hello.remote = "@third@" """) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteFeaturesSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteFeaturesSpec.scala index b5dba635c3..620bb900b8 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteFeaturesSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteFeaturesSpec.scala @@ -40,7 +40,7 @@ class RemotingFeaturesConfig(val useUnsafe: Boolean, artery: Boolean) extends Mu val iterationCount = 10 protected val baseConfig = ConfigFactory.parseString(s""" - akka.remote.use-unsafe-remote-features-without-cluster = $useUnsafe + akka.remote.use-unsafe-remote-features-outside-cluster = $useUnsafe akka.remote.log-remote-lifecycle-events = off akka.remote.artery.enabled = $artery akka.remote.artery.advanced.flight-recorder.enabled = off @@ -351,7 +351,7 @@ abstract class RemotingFeaturesSpec(val multiNodeConfig: RemotingFeaturesConfig) } } - s"Deploy routers with expected behavior if 'akka.remote.use-unsafe-remote-features-without-cluster=$useUnsafe'" must { + s"Deploy routers with expected behavior if 'akka.remote.use-unsafe-remote-features-outside-cluster=$useUnsafe'" must { "deployments" in { runOn(first, second, third, fourth) { val deployment1 = system.asInstanceOf[ActorSystemImpl].provider.deployer.lookup(List("service-hello")) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala index 9456ce14b8..dd8b6e0e52 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala @@ -29,7 +29,7 @@ class RemoteNodeDeathWatchConfig(artery: Boolean) extends MultiNodeConfig { ## Use a tighter setting than the default, otherwise it takes 20s for DeathWatch to trigger akka.remote.watch-failure-detector.acceptable-heartbeat-pause = 3 s akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)).withFallback(RemotingMultiNodeSpec.commonConfig)) } diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartDeathWatchSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartDeathWatchSpec.scala index bef3db0f39..66bcceba03 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartDeathWatchSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartDeathWatchSpec.scala @@ -30,7 +30,7 @@ class RemoteNodeRestartDeathWatchConfig(artery: Boolean) extends MultiNodeConfig akka.remote.classic.transport-failure-detector.heartbeat-interval = 1 s akka.remote.classic.transport-failure-detector.acceptable-heartbeat-pause = 3 s akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """))) testTransport(on = true) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteReDeploymentSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteReDeploymentSpec.scala index 83d2455df1..1d993c484e 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteReDeploymentSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteReDeploymentSpec.scala @@ -35,7 +35,7 @@ class RemoteReDeploymentConfig(artery: Boolean) extends MultiNodeConfig { acceptable-heartbeat-pause=2.5s } akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.loglevel = INFO """)).withFallback(RemotingMultiNodeSpec.commonConfig)) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala index 9f47d93414..50e1ffd3cf 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala @@ -29,7 +29,7 @@ object TransportFailConfig extends MultiNodeConfig { commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" akka.loglevel = INFO - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.remote.classic { transport-failure-detector { implementation-class = "akka.remote.TransportFailSpec$$TestFailureDetector" diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/SurviveNetworkPartitionSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/SurviveNetworkPartitionSpec.scala index 23060d777c..b63e3f68f3 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/SurviveNetworkPartitionSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/SurviveNetworkPartitionSpec.scala @@ -26,7 +26,7 @@ object SurviveNetworkPartitionSpec extends MultiNodeConfig { akka.loglevel = INFO akka.remote.artery.enabled = on akka.remote.artery.advanced.give-up-system-message-after = 4s - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)) .withFallback(RemotingMultiNodeSpec.commonConfig)) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/classic/RemoteNodeShutdownAndComesBackSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/classic/RemoteNodeShutdownAndComesBackSpec.scala index 3d0327888f..0e986b6908 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/classic/RemoteNodeShutdownAndComesBackSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/classic/RemoteNodeShutdownAndComesBackSpec.scala @@ -30,7 +30,7 @@ object RemoteNodeShutdownAndComesBackSpec extends MultiNodeConfig { akka.remote.classic.transport-failure-detector.heartbeat-interval = 1 s akka.remote.classic.transport-failure-detector.acceptable-heartbeat-pause = 3 s akka.remote.watch-failure-detector.acceptable-heartbeat-pause = 60 s - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """))) testTransport(on = true) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRandomSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRandomSpec.scala index 9c04c6b8f1..3dfbc8ff49 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRandomSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRandomSpec.scala @@ -27,7 +27,7 @@ class RemoteRandomConfig(artery: Boolean) extends MultiNodeConfig { commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)).withFallback(RemotingMultiNodeSpec.commonConfig)) deployOnAll(""" diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRoundRobinSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRoundRobinSpec.scala index 2870e639ec..372e5f720b 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRoundRobinSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRoundRobinSpec.scala @@ -26,7 +26,7 @@ class RemoteRoundRobinConfig(artery: Boolean) extends MultiNodeConfig { commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)).withFallback(RemotingMultiNodeSpec.commonConfig)) deployOnAll(""" diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteScatterGatherSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteScatterGatherSpec.scala index 5a1e32f592..ca13841ce4 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteScatterGatherSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteScatterGatherSpec.scala @@ -28,7 +28,7 @@ class RemoteScatterGatherConfig(artery: Boolean) extends MultiNodeConfig { commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(s""" akka.remote.artery.enabled = $artery - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """)).withFallback(RemotingMultiNodeSpec.commonConfig)) deployOnAll(""" diff --git a/akka-remote/src/main/resources/reference.conf b/akka-remote/src/main/resources/reference.conf index 68b9c909cb..b3fe202ed9 100644 --- a/akka-remote/src/main/resources/reference.conf +++ b/akka-remote/src/main/resources/reference.conf @@ -167,12 +167,12 @@ akka { # If Cluster is not used, remote watch and deployment are disabled. # To optionally use them while not using Cluster, set to 'on'. - use-unsafe-remote-features-without-cluster = off + use-unsafe-remote-features-outside-cluster = off # A warning will be logged on remote watch attempts if Cluster - # is not in use and 'use-unsafe-remote-features-without-cluster' + # is not in use and 'use-unsafe-remote-features-outside-cluster' # is 'off'. Set this to 'off' to suppress these. - warn-unsafe-watch-without-cluster = on + warn-unsafe-watch-outside-cluster = on # Settings for the Phi accrual failure detector (http://www.jaist.ac.jp/~defago/files/pdf/IS_RR_2004_010.pdf # [Hayashibara et al]) used for remote death watch. diff --git a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala index c2424b9cea..886d061a46 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala @@ -333,7 +333,7 @@ private[akka] class RemoteActorRefProvider( if (!settings.HasCluster) { if (remoteSettings.UseUnsafeRemoteFeaturesWithoutCluster) log.info( - "Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-without-cluster` has been enabled.") + "Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.") else log.warning("Akka Cluster not in use - Using Akka Cluster is recommended if you need remote watch and deploy.") } @@ -343,7 +343,7 @@ private[akka] class RemoteActorRefProvider( else log.debug(message) /** Logs if deathwatch message is intentionally dropped. To disable - * warnings set `akka.remote.warn-unsafe-watch-without-cluster` to `off` + * warnings set `akka.remote.warn-unsafe-watch-outside-cluster` to `off` * or use Akka Cluster. */ private[akka] def warnIfUnsafeDeathwatchWithoutCluster(watchee: ActorRef, watcher: ActorRef, action: String): Unit = diff --git a/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala b/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala index 6f09c1f4a5..c927609abf 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala @@ -160,9 +160,9 @@ final class RemoteSettings(val config: Config) { }.requiring(_.duration > Duration.Zero, "command-ack-timeout must be > 0") val UseUnsafeRemoteFeaturesWithoutCluster: Boolean = getBoolean( - "akka.remote.use-unsafe-remote-features-without-cluster") + "akka.remote.use-unsafe-remote-features-outside-cluster") - val WarnUnsafeWatchWithoutCluster: Boolean = getBoolean("akka.remote.warn-unsafe-watch-without-cluster") + val WarnUnsafeWatchWithoutCluster: Boolean = getBoolean("akka.remote.warn-unsafe-watch-outside-cluster") val WatchFailureDetectorConfig: Config = getConfig("akka.remote.watch-failure-detector") val WatchFailureDetectorImplementationClass: String = WatchFailureDetectorConfig.getString("implementation-class") diff --git a/akka-remote/src/main/scala/akka/remote/RemoteWatcher.scala b/akka-remote/src/main/scala/akka/remote/RemoteWatcher.scala index c52c719510..d194b4bb3c 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteWatcher.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteWatcher.scala @@ -202,7 +202,7 @@ private[akka] class RemoteWatcher( } } - /** Returns true if either has cluster or `akka.remote.use-unsafe-remote-features-without-cluster` + /** Returns true if either has cluster or `akka.remote.use-unsafe-remote-features-outside-cluster` * is enabled. Can be overridden when using RemoteWatcher as a superclass. */ @InternalApi protected def shouldWatch(@unused watchee: InternalActorRef): Boolean = { diff --git a/akka-remote/src/test/scala/akka/remote/RemoteFeaturesSpec.scala b/akka-remote/src/test/scala/akka/remote/RemoteFeaturesSpec.scala index 00c49946db..6ec74386e7 100644 --- a/akka-remote/src/test/scala/akka/remote/RemoteFeaturesSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/RemoteFeaturesSpec.scala @@ -32,7 +32,7 @@ object RemoteFeaturesSpec { // string config to pass into `ArteryMultiNodeSpec.extraConfig: Option[String]` for `other` system def common(useUnsafe: Boolean): String = s""" - akka.remote.use-unsafe-remote-features-without-cluster = $useUnsafe + akka.remote.use-unsafe-remote-features-outside-cluster = $useUnsafe akka.remote.artery.enabled = on akka.remote.artery.canonical.port = 0 akka.remote.artery.advanced.flight-recorder.enabled = off diff --git a/akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala b/akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala index abcdc2dcd7..09cd24330a 100644 --- a/akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala @@ -24,7 +24,7 @@ object RemoteRouterSpec { class RemoteRouterSpec extends AkkaSpec(s""" akka.actor.provider = remote akka.actor.serialize-messages = off - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.remote.classic.netty.tcp { hostname = localhost port = 0 diff --git a/akka-remote/src/test/scala/akka/remote/TypedActorRemoteDeploySpec.scala b/akka-remote/src/test/scala/akka/remote/TypedActorRemoteDeploySpec.scala index 09cc0eb269..2a72c40ce5 100644 --- a/akka-remote/src/test/scala/akka/remote/TypedActorRemoteDeploySpec.scala +++ b/akka-remote/src/test/scala/akka/remote/TypedActorRemoteDeploySpec.scala @@ -19,7 +19,7 @@ object TypedActorRemoteDeploySpec { akka.actor.provider = remote akka.remote.classic.netty.tcp.port = 0 akka.remote.artery.canonical.port = 0 - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.actor.allow-java-serialization = on """) diff --git a/akka-remote/src/test/scala/akka/remote/artery/RemoteDeathWatchSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/RemoteDeathWatchSpec.scala index 16f8f7072c..7c451fa557 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/RemoteDeathWatchSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/RemoteDeathWatchSpec.scala @@ -26,7 +26,7 @@ object RemoteDeathWatchSpec { } } test.filter-leeway = 10s - remote.use-unsafe-remote-features-without-cluster = on + remote.use-unsafe-remote-features-outside-cluster = on remote.watch-failure-detector.acceptable-heartbeat-pause = 2s # reduce handshake timeout for quicker test of unknownhost, but diff --git a/akka-remote/src/test/scala/akka/remote/artery/RemoteDeploymentSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/RemoteDeploymentSpec.scala index acbb104e7f..8700868438 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/RemoteDeploymentSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/RemoteDeploymentSpec.scala @@ -69,7 +69,7 @@ class RemoteDeploymentSpec extends ArteryMultiNodeSpec(ConfigFactory.parseString(""" akka.remote.artery.advanced.inbound-lanes = 10 akka.remote.artery.advanced.outbound-lanes = 3 - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on """).withFallback(ArterySpecSupport.defaultConfig)) { import RemoteDeploymentSpec._ diff --git a/akka-remote/src/test/scala/akka/remote/artery/RemoteRouterSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/RemoteRouterSpec.scala index 8fd220d2be..d24e0070b2 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/RemoteRouterSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/RemoteRouterSpec.scala @@ -24,7 +24,7 @@ object RemoteRouterSpec { class RemoteRouterSpec extends AkkaSpec(ConfigFactory.parseString(""" - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.actor.deployment { /remote-override { router = round-robin-pool diff --git a/akka-remote/src/test/scala/akka/remote/artery/RemoteWatcherSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/RemoteWatcherSpec.scala index 65843cd531..4d843c7d00 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/RemoteWatcherSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/RemoteWatcherSpec.scala @@ -70,7 +70,7 @@ object RemoteWatcherSpec { class RemoteWatcherSpec extends ArteryMultiNodeSpec( ConfigFactory - .parseString("akka.remote.use-unsafe-remote-features-without-cluster = on") + .parseString("akka.remote.use-unsafe-remote-features-outside-cluster = on") .withFallback(ArterySpecSupport.defaultConfig)) with ImplicitSender { diff --git a/akka-remote/src/test/scala/akka/remote/artery/SystemMessageDeliverySpec.scala b/akka-remote/src/test/scala/akka/remote/artery/SystemMessageDeliverySpec.scala index d40a97333a..5ac48be5bb 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/SystemMessageDeliverySpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/SystemMessageDeliverySpec.scala @@ -48,7 +48,7 @@ object SystemMessageDeliverySpec { """).withFallback(ArterySpecSupport.defaultConfig) val config = - ConfigFactory.parseString("akka.remote.use-unsafe-remote-features-without-cluster = on").withFallback(safe) + ConfigFactory.parseString("akka.remote.use-unsafe-remote-features-outside-cluster = on").withFallback(safe) } abstract class AbstractSystemMessageDeliverySpec(c: Config) extends ArteryMultiNodeSpec(c) with ImplicitSender { diff --git a/akka-remote/src/test/scala/akka/remote/artery/tcp/TlsTcpSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/tcp/TlsTcpSpec.scala index 38118abde9..6c5d5354d7 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/tcp/TlsTcpSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/tcp/TlsTcpSpec.scala @@ -185,7 +185,7 @@ class TlsTcpWithHostnameVerificationSpec akka.remote.artery.ssl.config-ssl-engine { hostname-verification = on } - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.loggers = ["akka.testkit.TestEventListener"] """).withFallback(TlsTcpSpec.config)) diff --git a/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala b/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala index 250ba5f667..c1a43afe85 100644 --- a/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala @@ -29,7 +29,7 @@ object ActorsLeakSpec { akka.remote.classic.transport-failure-detector.heartbeat-interval = 1 s akka.remote.classic.transport-failure-detector.acceptable-heartbeat-pause = 3 s akka.remote.classic.quarantine-after-silence = 3 s - akka.remote.use-unsafe-remote-features-without-cluster = on + akka.remote.use-unsafe-remote-features-outside-cluster = on akka.test.filter-leeway = 12 s # test is using Java serialization and not priority to rewrite akka.actor.allow-java-serialization = on diff --git a/akka-remote/src/test/scala/akka/remote/classic/RemoteDeathWatchSpec.scala b/akka-remote/src/test/scala/akka/remote/classic/RemoteDeathWatchSpec.scala index c4c57e8a7c..7328833764 100644 --- a/akka-remote/src/test/scala/akka/remote/classic/RemoteDeathWatchSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/classic/RemoteDeathWatchSpec.scala @@ -24,7 +24,7 @@ akka { } } - remote.use-unsafe-remote-features-without-cluster = on + remote.use-unsafe-remote-features-outside-cluster = on remote.artery.enabled = off remote.classic { retry-gate-closed-for = 1 s diff --git a/akka-remote/src/test/scala/akka/remote/classic/RemoteDeploymentWhitelistSpec.scala b/akka-remote/src/test/scala/akka/remote/classic/RemoteDeploymentWhitelistSpec.scala index 693f89df76..70a5d9fea3 100644 --- a/akka-remote/src/test/scala/akka/remote/classic/RemoteDeploymentWhitelistSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/classic/RemoteDeploymentWhitelistSpec.scala @@ -57,7 +57,7 @@ object RemoteDeploymentWhitelistSpec { actor.provider = remote remote { - use-unsafe-remote-features-without-cluster = on + use-unsafe-remote-features-outside-cluster = on classic.enabled-transports = [ "akka.remote.test", "akka.remote.classic.netty.tcp" diff --git a/akka-remote/src/test/scala/akka/remote/classic/RemoteWatcherSpec.scala b/akka-remote/src/test/scala/akka/remote/classic/RemoteWatcherSpec.scala index 8b38141bd4..24e68f466e 100644 --- a/akka-remote/src/test/scala/akka/remote/classic/RemoteWatcherSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/classic/RemoteWatcherSpec.scala @@ -78,7 +78,7 @@ class RemoteWatcherSpec extends AkkaSpec(""" port = 0 } remote.artery.enabled = off - remote.use-unsafe-remote-features-without-cluster = on + remote.use-unsafe-remote-features-outside-cluster = on } # test is using Java serialization and not priority to rewrite akka.actor.allow-java-serialization = on diff --git a/akka-remote/src/test/scala/akka/remote/classic/RemotingSpec.scala b/akka-remote/src/test/scala/akka/remote/classic/RemotingSpec.scala index ba88ea4421..f8f6965fad 100644 --- a/akka-remote/src/test/scala/akka/remote/classic/RemotingSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/classic/RemotingSpec.scala @@ -89,7 +89,7 @@ object RemotingSpec { actor.warn-about-java-serializer-usage = off remote { - use-unsafe-remote-features-without-cluster = on + use-unsafe-remote-features-outside-cluster = on artery.enabled = off classic { retry-gate-closed-for = 1 s diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala index 118885a37a..e4866060df 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala @@ -157,7 +157,7 @@ object StreamRefsSpec { remote { artery.canonical.port = 0 classic.netty.tcp.port = 0 - use-unsafe-remote-features-without-cluster = on + use-unsafe-remote-features-outside-cluster = on } } """).withFallback(ConfigFactory.load())