Ah, thanks. I had thought the ActorSystem was a singleton of some sort. On Friday, June 24, 2016 at 1:37:34 AM UTC-4, Martynas Mickevičius wrote: > > Hi, > > it looks like you are not passing your custom parsed and loaded > configuration to actor system constructor: ActorSystem(_configName). > > On Thu, Jun 9, 2016 at 10:05 PM, Ian Nowland <[email protected] > <javascript:>> wrote: > >> Further investigation has shown me that the same configurations, added to >> my BaseConfiguration do work, so something about the load of this secondary >> file is causing the configuration to be un-runnable. >> >> >> On Thursday, June 9, 2016 at 1:29:05 PM UTC-4, Ian Nowland wrote: >>> >>> I'm trying to test that I'm loading configurations properly, and just >>> can't seem to create the configuration properly - and getting nowhere in >>> tracking down what I'm doing wrong on my own. >>> >>> Here's a configuration I've created just to try and verify things are >>> working: >>> >>> TaskScheduler { >>> dispatcher = TaskScheduler-dispatcher >>> } >>> >>> TaskScheduler-dispatcher { >>> type = Dispatcher >>> executor = "thread-pool-executor" >>> thread-pool-executor { >>> fixed-pool-size = 1 >>> } >>> } >>> >>> My code that's loading the configuration is following this example >>> <http://doc.akka.io/docs/akka/snapshot/general/configuration.html>, and >>> is succeeding without error: >>> >>> private def combine(content:String,name:String) = >>> StringUtils.filterEmpty(content).flatMap(conf => { >>> Try(ConfigFactory.parseString(conf)).recoverWith({ >>> case t:Throwable => >>> Log.warn(s"Unable to parse akka configuration ${name}",t) >>> Failure(t) >>> }).toOption >>> }).flatMap(config => { >>> >>> Try(ConfigFactory.load(config.withFallback(typesafeConfig))).recoverWith({ >>> case t:Throwable => >>> Log.warn(s"Unable to apply akka configuration ${name} with >>> default configuration",t) >>> Failure(t) >>> }).toOption >>> }).foreach(config => { >>> Log.info(s"Setting akka configuration to include ${name}") >>> BaseConfiguration.typesafeConfig = config}) >>> >>> However, my code to actually take advantage of the configuration looks >>> like this, and is failing: >>> >>> Try({ >>> Log.info(s"Found akka configuration for $configName as >>> ${BaseConfiguration.typesafeConfig.getAnyRef(_configName)}") >>> val _system = ActorSystem(_configName) >>> Log.info(s"Found akka dispatcher configuration for >>> ${dispatcherName(_configName)} as >>> ${BaseConfiguration.typesafeConfig.getAnyRef(dispatcherName(_configName))}") >>> _system.dispatchers.lookup(dispatcherName(_configName)) >>> }).recoverWith({ >>> case t:Throwable => >>> Log.debug(s"When loading akka configuration ${_configName}:",t) >>> Failure(t) >>> }) >>> >>> >>> showing up like this: >>> >>> >>> INFO [2016-06-09 17:17:58,036] habari: [ewdE8B4L]Found akka >>> configuration for Some(TaskScheduler) as >>> {dispatcher=TaskScheduler-dispatcher} >>> INFO [2016-06-09 17:17:58,042] habari: [ewdE8B4L]Found akka dispatcher >>> configuration for TaskScheduler-dispatcher as >>> {executor=thread-pool-executor, thread-pool-executor={fixed-pool-size=1}, >>> type=Dispatcher} >>> DEBUG [2016-06-09 17:17:58,043] habari: [ewdE8B4L]When loading akka >>> configuration TaskScheduler:Dispatcher [TaskScheduler-dispatcher] not >>> configured: akka.ConfigurationException: Dispatcher >>> [TaskScheduler-dispatcher] not configured >>> >>> I think there's something simple that I'm missing just in the name of >>> the dispatcher I'm asking for, but there doesn't seem to be any way to list >>> the names of the dispatchers the ActorSystem has, so I can't figure out any >>> way to check what the dispatcher I've configured is actually called. Can >>> anyone clue me in on what I'm doing wrong? >>> >> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to [email protected] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at https://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > >
-- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
