Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def init(dbType: DatabaseType.Value)(implicit system: ActorSystem): Unit = {
- try {
- Database.init(dbType)
- DatabaseUpdater.runUpdate(dbType)
- } catch {
- case e: Exception =>
- log.error(s"couldn't init database, exiting now", e)
- System.exit(1)
- }
- //TODO: create one main actor for supervising startup order
- system.actorOf(Props[BrandexRouter], ActorNames.Router)
- system.actorOf(Props[ViewCreator], ActorNames.ViewCreator)
- system.actorOf(Props[StatsCollector], ActorNames.ServerStats)
- //wait for loading open orders
- Thread.sleep(30000L)
- Trading.init()
- //wait for trading module start up
- Thread.sleep(30000L)
- Analytics.init()
- system.actorOf(Props[DatabaseCleaner], ActorNames.DatabaseCleaner)
- Runtime.getRuntime.addShutdownHook(new Thread() {
- override def run() {
- system.shutdown()
- system.awaitTermination()
- Database.close()
- }
- })
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement