raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
pekko/akka-remote/src/test/scala/akka/remote/RemoteConfigSpec.scala

61 lines
2.9 KiB
Scala
Raw Normal View History

Modularize configuration. See #1361 * Split config reference to one for each module/extension. * Adjusted signature of registerExtension to avoid race of extension init * Moved Duration.dilated to testkit * TestKitExtension * RemoteExtension * SerializationExtension * Durable mailboxes extensions * Fixed broken serialization bindings and added test * Updated configuration documentation * System properties akka.remote.hostname akka.remote.port replaced with akka.remote.server.hostname and akka.remote.server.port * Adjustments of ActorSystem initialization. Still don't like the two-phase constructor/init flow. Very fragile for changes. Review fixes. SerializationExtension
2011-11-22 13:04:10 +01:00
package akka.remote
ticket 885
2011-07-20 11:14:51 +03:00
make akka-actor-tests compile again
2011-10-11 16:05:48 +02:00
import akka.testkit.AkkaSpec
ticket 885
2011-07-20 11:14:51 +03:00
make most AkkaSpec-based tests runnable in Eclipse
2011-10-21 17:01:22 +02:00
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
Removing nodename
2012-01-17 15:25:26 +01:00
class RemoteConfigSpec extends AkkaSpec("") {
ticket 885
2011-07-20 11:14:51 +03:00
First walk throught of FIXME. See #1378 * Fixed obvious * Created tickets for several, #1408, #1409, #1410, #1412, #1415, 1416, #1418 * Moved LoggingReceive from akka.actor to akka.event * Touched several of the FIXME to make them visible in code review
2011-11-30 10:20:57 +01:00
"RemoteExtension" must {
"be able to parse remote and cluster config elements" in {
make akka-actor-tests compile again
2011-10-11 16:05:48 +02:00
make remote lookup work - create RemoteActorRef in actorFor - simplify send/receive because Futures/Exceptions do not go over the wire anymore - add RemoteCommunicationSpec which uses two ActorSystems communicating in the same JVM via TCP socket
2011-12-08 14:44:05 +01:00
val config = system.settings.config
make akka-actor-tests compile again
2011-10-11 16:05:48 +02:00
import config._
ticket 885
2011-07-20 11:14:51 +03:00
Fixed problems with remote configuration. Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-25 15:42:25 +01:00
//akka.remote
#1424 - RemoteSupport is now instantiated from the config, so now anyone can write their own Akka transport layer for remote actors
2011-12-02 18:08:13 +01:00
getString("akka.remote.transport") must equal("akka.remote.netty.NettyRemoteSupport")
Fixed problems with remote configuration. Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-25 15:42:25 +01:00
getString("akka.remote.secure-cookie") must equal("")
getBoolean("akka.remote.use-passive-connections") must equal(true)
Adding backoff-timeout to remote configuration
2011-12-30 17:24:23 +01:00
getMilliseconds("akka.remote.backoff-timeout") must equal(0)
Fixed problems with remote configuration. Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-25 15:42:25 +01:00
// getMilliseconds("akka.remote.remote-daemon-ack-timeout") must equal(30 * 1000)
Modularize configuration. See #1361 * Split config reference to one for each module/extension. * Adjusted signature of registerExtension to avoid race of extension init * Moved Duration.dilated to testkit * TestKitExtension * RemoteExtension * SerializationExtension * Durable mailboxes extensions * Fixed broken serialization bindings and added test * Updated configuration documentation * System properties akka.remote.hostname akka.remote.port replaced with akka.remote.server.hostname and akka.remote.server.port * Adjustments of ActorSystem initialization. Still don't like the two-phase constructor/init flow. Very fragile for changes. Review fixes. SerializationExtension
2011-11-22 13:04:10 +01:00
//akka.remote.server
getInt("akka.remote.server.port") must equal(2552)
Updated to latest config lib and changed how reference config files are loaded. * Config lib 4f3a91f * All reference files named reference.conf, all will be loaded * Usage of ConfigFactor.load as default way * Extensions use same config as ActorSystem.settings.config
2011-11-29 11:50:22 +01:00
getBytes("akka.remote.server.message-frame-size") must equal(1048576L)
Modularize configuration. See #1361 * Split config reference to one for each module/extension. * Adjusted signature of registerExtension to avoid race of extension init * Moved Duration.dilated to testkit * TestKitExtension * RemoteExtension * SerializationExtension * Durable mailboxes extensions * Fixed broken serialization bindings and added test * Updated configuration documentation * System properties akka.remote.hostname akka.remote.port replaced with akka.remote.server.hostname and akka.remote.server.port * Adjustments of ActorSystem initialization. Still don't like the two-phase constructor/init flow. Very fragile for changes. Review fixes. SerializationExtension
2011-11-22 13:04:10 +01:00
getMilliseconds("akka.remote.server.connection-timeout") must equal(120 * 1000)
getBoolean("akka.remote.server.require-cookie") must equal(false)
getBoolean("akka.remote.server.untrusted-mode") must equal(false)
getInt("akka.remote.server.backlog") must equal(4096)
Switching to using OrderedMemoryAware executor same for all of the remoting, added more remote config tests and switched to mem size conf
2011-12-30 12:04:20 +01:00
getMilliseconds("akka.remote.server.execution-pool-keepalive") must equal(60 * 1000)
getInt("akka.remote.server.execution-pool-size") must equal(4)
getBytes("akka.remote.server.max-channel-memory-size") must equal(0)
getBytes("akka.remote.server.max-total-memory-size") must equal(0)
Modularize configuration. See #1361 * Split config reference to one for each module/extension. * Adjusted signature of registerExtension to avoid race of extension init * Moved Duration.dilated to testkit * TestKitExtension * RemoteExtension * SerializationExtension * Durable mailboxes extensions * Fixed broken serialization bindings and added test * Updated configuration documentation * System properties akka.remote.hostname akka.remote.port replaced with akka.remote.server.hostname and akka.remote.server.port * Adjustments of ActorSystem initialization. Still don't like the two-phase constructor/init flow. Very fragile for changes. Review fixes. SerializationExtension
2011-11-22 13:04:10 +01:00
//akka.remote.client
getMilliseconds("akka.remote.client.reconnect-delay") must equal(5 * 1000)
getMilliseconds("akka.remote.client.read-timeout") must equal(3600 * 1000)
getMilliseconds("akka.remote.client.reconnection-time-window") must equal(600 * 1000)
Updated documentation of Actors Scala. See #1435
2011-12-06 16:49:39 +01:00
// TODO cluster config will go into akka-cluster/reference.conf when we enable that module
ticket 885
2011-07-20 11:14:51 +03:00
//akka.cluster
Fixed problems with remote configuration. Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-25 15:42:25 +01:00
getStringList("akka.cluster.seed-nodes") must equal(new java.util.ArrayList[String])
// getMilliseconds("akka.cluster.max-time-to-wait-until-connected") must equal(30 * 1000)
// getMilliseconds("akka.cluster.session-timeout") must equal(60 * 1000)
// getMilliseconds("akka.cluster.connection-timeout") must equal(60 * 1000)
// getBoolean("akka.cluster.include-ref-node-in-replica-set") must equal(true)
// getString("akka.cluster.log-directory") must equal("_akka_cluster")
// //akka.cluster.replication
// getString("akka.cluster.replication.digest-type") must equal("MAC")
// getString("akka.cluster.replication.password") must equal("secret")
// getInt("akka.cluster.replication.ensemble-size") must equal(3)
// getInt("akka.cluster.replication.quorum-size") must equal(2)
// getInt("akka.cluster.replication.snapshot-frequency") must equal(1000)
// getMilliseconds("akka.cluster.replication.timeout") must equal(30 * 1000)
ticket 885
2011-07-20 11:14:51 +03:00
}
}
}
Reference in a new issue Copy permalink