don’t encourage thread leaks so easily (initialCommands)
This commit is contained in:
parent
57bf823532
commit
dc9968dda7
1 changed files with 2 additions and 2 deletions
|
|
@ -42,10 +42,10 @@ object AkkaBuild extends Build {
|
||||||
|import com.typesafe.config.ConfigFactory
|
|import com.typesafe.config.ConfigFactory
|
||||||
|import akka.util.duration._
|
|import akka.util.duration._
|
||||||
|import akka.util.Timeout
|
|import akka.util.Timeout
|
||||||
|val config = ConfigFactory.parseString("akka.daemonic=on")
|
|val config = ConfigFactory.parseString("akka.stdout-loglevel=INFO,akka.loglevel=DEBUG")
|
||||||
|val remoteConfig = ConfigFactory.parseString("akka.remote.netty{port=0,use-dispatcher-for-io=akka.actor.default-dispatcher,execution-pool-size=0},akka.actor.provider=RemoteActorRefProvider").withFallback(config)
|
|val remoteConfig = ConfigFactory.parseString("akka.remote.netty{port=0,use-dispatcher-for-io=akka.actor.default-dispatcher,execution-pool-size=0},akka.actor.provider=RemoteActorRefProvider").withFallback(config)
|
||||||
|var system: ActorSystem = null
|
|var system: ActorSystem = null
|
||||||
|def startSystem(remoting: Boolean = false) { system = ActorSystem("repl", if(remoting) remoteConfig else config) }
|
|def startSystem(remoting: Boolean = false) { system = ActorSystem("repl", if(remoting) remoteConfig else config); println("don’t forget to system.shutdown()!") }
|
||||||
|implicit def ec = system.dispatcher
|
|implicit def ec = system.dispatcher
|
||||||
|implicit val timeout = Timeout(5 seconds)
|
|implicit val timeout = Timeout(5 seconds)
|
||||||
|""".stripMargin,
|
|""".stripMargin,
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue