Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- case msg @ UpdateKeywordsConf(kwConfig) ⇒
- log.warning("Update keywords config: {}", kwConfig)
- keywordsConf = Some(kwConfig)
- unstashAll()
- context.system.eventStream.publish(msg)
- ....
- ....
- ....
- override def preStart() {
- context.become({
- case kw: KeywordsConfig ⇒
- updateKeywords(kw)
- context.unbecome()
- unstashAll()
- context.system.eventStream.subscribe(self, classOf[UpdateKeywordsConf])
- case _ ⇒ stash()
- })
Advertisement
Add Comment
Please, Sign In to add comment